def configure()

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}")