GoogleCloudPlatform / data-migration-tool

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 236 units with 4,811 lines of code in units (46.1% of code).

0 very complex units (0 lines of code)
1 complex units (170 lines of code)
8 medium complex units (626 lines of code)
25 simple units (869 lines of code)
202 very simple units (3,146 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
def _process_transfer_logs() in src/datamigration/dags/teradata/teradata_transfer_run_log_dag.py	170	31	1
def _dry_run() in src/translation/dags/dml_validation_dag.py	138	22	2
def _determine_next_dag() in src/translation/dags/controller_dag.py	52	21	2
def execute() in src/common_utils/operators/reporting_operator.py	93	21	2
def _process_transfer_logs() in src/datamigration/dags/redshift/redshift_transfer_run_log_dag.py	95	20	1
def filter() in src/common_utils/table_filter.py	110	19	2
def index() in src/translation/event_listener/main.py	46	16	0
def normalize_and_validate_config() in src/translation/dags/translation_utils/input_validation_utils.py	44	13	2
def _prepare_data_for_next_dag() in src/translation/dags/controller_dag.py	48	12	2
def _get_failed_files_from_csv() in src/translation/dags/batch_sql_translation.py	41	10	1
def get_inc_table_list_for_copy() in src/datamigration/dags/datamigration_utils/hive_bq_load_utils_inc.py	30	10	2
def _get_table_or_file_list() in src/translation/dags/validation_crun_dag.py	47	9	1
def rules_filter() in src/translation/dags/translation_utils/csv_utils.py	19	9	1
def parallelize_dvt_tasks() in src/translation/dags/validation_dag.py	44	9	1
def run_script_files() in src/common_utils/bigquery_client_utils/ddl.py	41	9	4
def get_hive_ddls() in src/translation/scripts/hive/extract_hive_ddls_manual.py	89	8	3
def get_hive_ddls() in src/translation/scripts/hive/extract_hive_ddls.py	70	8	3
def _execute_queries() in src/translation/dags/schema_dag.py	51	7	2
def connection_string() in src/translation/dvt/main.py	19	6	1
def _save_dvt_aggregated_results() in src/translation/dags/validation_crun_dag.py	30	6	1
def _prepare_config_for_reporting() in src/translation/dags/controller_dag.py	29	6	2
def pattern_filter() in src/translation/dags/translation_utils/csv_utils.py	10	6	1
def _extract_redshift_ddl() in src/translation/dags/translation_utils/ddl_extraction_utils/build_redshift_ddl_extraction_group.py	60	6	2
def _save_dvt_aggregated_results() in src/translation/dags/validation_dag.py	30	6	1
def _get_all_translated_files() in src/translation/dags/batch_sql_translation.py	20	6	1
def _determine_next_dag() in src/translation/dags/batch_sql_translation.py	20	6	1
def _save_stats() in src/translation/dags/batch_sql_translation.py	58	6	1
def _setup_agent() in src/datamigration/scripts/teradata/agent_controller/controller.py	37	6	1
def partition_cluster_col_subcmd_1() in src/datamigration/dags/datamigration_utils/hive_bq_load_utils_inc.py	20	6	3
def get_job_status() in src/datamigration/dags/datamigration_utils/hive_bq_load_utils_inc.py	28	6	2
def partition_cluster_col_subcmd_1() in src/datamigration/dags/datamigration_utils/hive_bq_load_utils.py	20	6	3
def get_job_status() in src/datamigration/dags/datamigration_utils/hive_bq_load_utils.py	28	6	2
def _check_filtered_tables() in src/datamigration/dags/redshift/redshift_transfer_run_log_dag.py	14	6	1
def _check_filtered_tables() in src/datamigration/dags/teradata/teradata_transfer_run_log_dag.py	14	6	1
def get_table_format() in src/translation/scripts/hive/extract_hive_ddls_manual.py	15	5	3
def get_table_format() in src/translation/scripts/hive/extract_hive_ddls.py	15	5	3
def _create_dataset() in src/translation/dags/schema_dag.py	16	5	1
def _determine_next_taskgroup_from_source() in src/translation/dags/extract_ddl_dag.py	20	5	2
def connection_string() in src/translation/dags/validation_dag.py	17	5	1
def _get_successfully_translated_files() in src/translation/dags/batch_sql_translation.py	20	5	1
def read_translation_config() in src/translation/scripts/hive/extract_hive_ddls_manual.py	32	4	1
def read_translation_config() in src/translation/scripts/hive/extract_hive_ddls.py	20	4	1
def get_dvt_cmd_ddl_validation() in src/translation/dvt/main.py	50	4	3
def run() in src/translation/dvt/main.py	35	4	0
def _invoke_cloud_run() in src/translation/dags/validation_crun_dag.py	36	4	1
def _save_dry_run_result() in src/translation/dags/dml_validation_dag.py	36	4	2
def _load_config() in src/translation/dags/controller_dag.py	27	4	2
def _store_ddl() in src/translation/dags/translation_utils/ddl_extraction_utils/build_teradata_ddl_extraction_group.py	45	4	2
def get_dvt_cmd_ddl_validation() in src/translation/dags/validation_dag.py	49	4	3
def _download_files() in src/translation/dags/batch_sql_translation.py	26	4	1