def run_scan()

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

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

def run_scan(**kwargs):
    params = kwargs['params']
    
    #trigger run scan 
    run_data_scan_task = DataplexRunDataQualityScanOperator(
        task_id="run_data_scan_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)
    )
    run_data_scan_task.execute(dict())