def run_dataflow_job_or_get_status()

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

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

def run_dataflow_job_or_get_status(job_id: str, dataflow_job_name: str, job_name: str, request_json):
    request_json = request_json
    if job_id:
        return get_dataflow_state(job_id, job_name, request_json)
    else:
        return run_dataflow_job(dataflow_job_name, job_name, request_json)