def _check_filtered_tables()

in src/datamigration/dags/teradata/teradata_transfer_run_log_dag.py [0:0]

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

def _check_filtered_tables(ti):
    valid_comparisons_list = ti.xcom_pull(
        task_ids="filter_tables_for_dvt", key="dvt_table_list"
    )
    if not valid_comparisons_list:
        # if empty list, skip calling validation dag and call dummy task (to mark end of DAG's functionality)
        logging.info(
            "Method _check_filtered_tables: no valid dvt comparisons list found"
        )
        return "skip_validation_dag"
    else:
        # if non-empty list, determine validation dag to be called and skip invoking dummy task
        logging.info(
            f"Method _check_filtered_tables: valid dvt comparisons list - {valid_comparisons_list}"
        )
        return "determine_validation_dag"