def get_scan_result()

in datascan/airflow/dq_runSync_evaluate_config_dag.py [0:0]

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

def get_scan_result(**kwargs):
    params = kwargs['params']
    
    #trigger job result scan 
    get_job_result_task = DataplexGetDataQualityScanResultOperator(
        task_id="get_data_scan_job_result_v1",
        project_id=params.get("project_id", DEFAULT_PROJECT_ID),
        region=params.get("region", DEFAULT_REGION),
        dag=dag,
        data_scan_id=params.get("data_scan_id", DEFAULT_DATA_SCAN_ID)
    )
    return get_job_result_task.execute(dict())