def execute_job_or_get_status()

in functions/data-processing-engines/dataproc-serverless-job-executor/main.py [0:0]

• 5 lines of code
• 2 McCabe index (conditional complexity)

def execute_job_or_get_status(job_id, workflow_name, job_name, query_variables, workflow_properties, extracted_params):
    if job_id:
        return get_job_status(job_id, extracted_params)
    else:
        return create_batch_job(workflow_name, job_name, query_variables, workflow_properties, extracted_params)