mozilla / telemetry-airflow - Conditional Complexity

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 132 units with 1,918 lines of code in units (21.4% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
12 medium complex units (438 lines of code)
12 simple units (222 lines of code)
108 very simple units (1,258 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 has_min_update_ping_count_mapper() in jobs/update_orphaning_dashboard_etl.py	34	18	1
def longitudinal_shim_transform() in jobs/update_orphaning_dashboard_etl.py	88	15	3
def state_code_stage_mapper() in jobs/update_orphaning_dashboard_etl.py	29	14	1
def state_failure_code_stage_mapper() in jobs/update_orphaning_dashboard_etl.py	29	14	1
def state_code_startup_mapper() in jobs/update_orphaning_dashboard_etl.py	29	14	1
def state_failure_code_startup_mapper() in jobs/update_orphaning_dashboard_etl.py	29	14	1
def get_rows() in jobs/socorro_import_crash_data.py	30	13	1
def is_supported_mapper() in jobs/update_orphaning_dashboard_etl.py	17	12	1
def has_update_enabled_mapper() in jobs/update_orphaning_dashboard_etl.py	14	12	1
def create_cluster() in utils/dataproc.py	76	11	1
def bqetl_backfill_dag() in dags/bqetl_backfill.py	51	11	0
def has_only_no_update_found_mapper() in jobs/update_orphaning_dashboard_etl.py	12	11	1
def check_code_notify_mapper() in jobs/update_orphaning_dashboard_etl.py	19	10	1
def download_code_mapper() in jobs/update_orphaning_dashboard_etl.py	21	10	1
def is_able_to_apply_mapper() in jobs/update_orphaning_dashboard_etl.py	14	9	1
def has_no_download_code_mapper() in jobs/update_orphaning_dashboard_etl.py	15	9	1
def check_ex_error_notify_mapper() in jobs/update_orphaning_dashboard_etl.py	15	8	1
def has_min_subsession_length_mapper() in jobs/update_orphaning_dashboard_etl.py	21	7	1
def has_update_apply_failure_mapper() in jobs/update_orphaning_dashboard_etl.py	13	7	1
def submit_job() in jobs/telemetry_batch_view.py	14	7	0
def process_pod_deletion() in operators/gcp_container_operator.py	24	7	4
def get_dataproc_parameters() in utils/dataproc.py	30	6	1
def generate_backfill_command() in utils/backfill.py	21	6	1
def replace_definitions() in jobs/socorro_import_crash_data.py	15	6	2
def retry_tasks_callback() in utils/callbacks.py	12	5	2
def latest_version_on_date() in jobs/update_orphaning_dashboard_etl.py	9	5	2
def has_out_of_date_max_version_mapper() in jobs/update_orphaning_dashboard_etl.py	10	5	1
def _format_envvar() in utils/dataproc.py	2	4	1
def set_main() in utils/patched/dataproc_hook.py	7	4	3
def has_update_ping_mapper() in jobs/update_orphaning_dashboard_etl.py	7	4	1
def retrieve_jar() in jobs/telemetry_batch_view.py	19	4	0
def validate_regex_pattern() in utils/backfill.py	8	3	1
def __getattr__() in utils/tags.py	8	3	2
def base_backfill_operator() in dags/shredder_backfill.py	20	3	1
def initiate_backfill() in dags/bqetl_backfill_initiate.py	50	3	1
def complete_backfill() in dags/bqetl_backfill_complete.py	43	3	1
def choose_branch() in dags/probe_scraper.py	8	3	2
def backfill() in jobs/socorro_import_crash_data.py	8	3	3
def ltv_prob_alive() in jobs/ltv_daily.py	10	3	1
def get_airflow_version() in plugins/version_endpoint.py	10	3	0
def get_dockerflow_version() in plugins/version_endpoint.py	9	3	0
def validate_date_range() in utils/backfill.py	7	2	1
def normalize_table_id() in utils/gcp.py	5	2	1
def add_labels() in utils/patched/dataproc_hook.py	3	2	2
def add_variables() in utils/patched/dataproc_hook.py	3	2	2
def add_args() in utils/patched/dataproc_hook.py	3	2	2
def add_jar_file_uris() in utils/patched/dataproc_hook.py	3	2	2
def add_archive_uris() in utils/patched/dataproc_hook.py	3	2	2
def add_file_uris() in utils/patched/dataproc_hook.py	3	2	2
def add_python_file_uris() in utils/patched/dataproc_hook.py	3	2	2