in modules/python/fio/fio.py [0:0]
def configure(yaml_path, replicas, operation_timeout_in_minutes=10):
deployment_template = KUBERNETES_CLIENT.create_template(
yaml_path, {"REPLICAS": replicas}
)
deployment_name = KUBERNETES_CLIENT.create_deployment(deployment_template)
logger.info(f"Deployment {deployment_name} created successfully!")
pods = KUBERNETES_CLIENT.wait_for_pods_ready(
label_selector="test=fio", pod_count=replicas, operation_timeout_in_minutes=operation_timeout_in_minutes
)
for pod in pods:
pod_name = pod.metadata.name
logs = KUBERNETES_CLIENT.get_pod_logs(pod_name)
logger.info(f"Checking logs for pod {pod_name}:\n{logs}")