def execute()

in modules/python/fio/fio.py [0:0]

• 9 lines of code
• 1 McCabe index (conditional complexity)

def execute(block_size, iodepth, method, runtime, result_dir):
    os.makedirs(result_dir, exist_ok=True)
    logger.info(f"Result directory: {result_dir}")

    pods = KUBERNETES_CLIENT.get_pods_by_namespace(namespace="default", label_selector="test=fio")
    pod_name = pods[0].metadata.name
    mount_path = pods[0].spec.containers[0].volume_mounts[0].mount_path
    logger.info(f"Executing fio benchmark on pod {pod_name} with mount path {mount_path}")

    file_path=f"{mount_path}/benchtest"
    base_command = f"fio --name=benchtest --size={FILE_SIZE} --filename={file_path} --direct=1 --ioengine=libaio --time_based \