apache / 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 15,010 units with 154,412 lines of code in units (40.7% of code).

1 very complex units (102 lines of code)
24 complex units (2,162 lines of code)
324 medium complex units (14,186 lines of code)
968 simple units (22,911 lines of code)
13,693 very simple units (115,051 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 auth_user_ldap() in providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py	102	56	3
def deserialize() in airflow-core/src/airflow/serialization/serialized_objects.py	95	44	2
def _get_conn_params() in providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake.py	91	41	1
def _handle_request() in task-sdk/src/airflow/sdk/execution_time/supervisor.py	167	38	3
def conversion_v1_to_v2() in airflow-core/src/airflow/serialization/serialized_objects.py	101	38	1
def _build_spark_submit_command() in providers/apache/spark/src/airflow/providers/apache/spark/hooks/spark_submit.py	77	38	2
def get_conn() in providers/oracle/src/airflow/providers/oracle/hooks/oracle.py	79	38	1
def _executable_task_instances_to_queued() in airflow-core/src/airflow/jobs/scheduler_job_runner.py	251	37	3
def update_config() in airflow-core/src/airflow/cli/commands/config_command.py	103	37	1
def compose_file() in dev/breeze/src/airflow_breeze/params/shell_params.py	86	32	1
def populate_operator() in airflow-core/src/airflow/serialization/serialized_objects.py	93	31	4
def execute() in providers/amazon/src/airflow/providers/amazon/aws/operators/redshift_cluster.py	88	31	2
def execute() in providers/sftp/src/airflow/providers/sftp/operators/sftp.py	96	31	2
def get_dag() in airflow-core/src/airflow/models/dagbag.py	51	30	3
def get_conn() in providers/microsoft/winrm/src/airflow/providers/microsoft/winrm/hooks/winrm.py	86	30	1
def filter_for_tis() in airflow-core/src/airflow/models/taskinstance.py	66	29	1
def deserialize() in airflow-core/src/airflow/serialization/serde.py	53	28	3
def _column_mapping_validation() in providers/common/sql/src/airflow/providers/common/sql/operators/sql.py	51	28	3
def get_plugin_info() in airflow-core/src/airflow/plugins_manager.py	49	27	1
def cleanup() in providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py	46	27	3
def _apply_defaults() in task-sdk/src/airflow/sdk/bases/operator.py	65	26	2
def dag_edges() in airflow-core/src/airflow/utils/dag_edges.py	55	26	1
def connections_add() in airflow-core/src/airflow/cli/commands/connection_command.py	80	26	1
def execute() in providers/google/src/airflow/providers/google/cloud/transfers/gcs_to_bigquery.py	117	26	2
def _build_cluster_data() in providers/google/src/airflow/providers/google/cloud/operators/dataproc.py	116	26	1
def change_ownership_of_files() in scripts/in_container/run_fix_ownership.py	49	25	1
def set_work_task_roots_and_leaves() in airflow-core/src/airflow/utils/setup_teardown.py	35	25	1
def _iter_template_context_keys_from_original_return() in scripts/ci/pre_commit/check_template_context_variable_in_sync.py	37	24	0
def expand_mapped_task() in airflow-core/src/airflow/models/taskmap.py	108	24	5
def _refresh_dag_bundles() in airflow-core/src/airflow/dag_processing/manager.py	74	24	3
def deserialize_dag() in airflow-core/src/airflow/serialization/serialized_objects.py	59	24	3
def execute() in providers/google/src/airflow/providers/google/cloud/operators/dataproc.py	81	24	2
def check_doc_files() in scripts/in_container/run_provider_yaml_files_check.py	75	23	2
def enter_shell() in dev/breeze/src/airflow_breeze/utils/docker_command_utils.py	58	23	2
def to_orm() in airflow-core/src/airflow/api_fastapi/common/parameters.py	39	23	2
def get_oauth_user_info() in providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py	95	23	4
def execute() in providers/google/src/airflow/providers/google/cloud/operators/bigquery.py	93	23	2
def get_uri() in task-sdk/src/airflow/sdk/definitions/connection.py	46	22	1
def _build_metrics() in airflow-core/src/airflow/utils/cli.py	63	22	2
def action_logging() in airflow-core/src/airflow/api_fastapi/logging/decorators.py	75	22	1
def _handle_request() in airflow-core/src/airflow/jobs/triggerer_job_runner.py	90	22	3
def _start_queued_dagruns() in airflow-core/src/airflow/jobs/scheduler_job_runner.py	92	22	2
def rpcapi_v2() in providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_routes.py	46	22	2
def build_task_kwargs() in providers/amazon/src/airflow/providers/amazon/aws/executors/ecs/ecs_executor_config.py	51	22	0
def get_conn() in providers/google/src/airflow/providers/google/cloud/hooks/compute_ssh.py	74	22	1
def _get_conn_config_mysql_client() in providers/mysql/src/airflow/providers/mysql/hooks/mysql.py	47	22	2
def get_fs() in providers/microsoft/azure/src/airflow/providers/microsoft/azure/fs/adls.py	51	22	3
def dag() in task-sdk/src/airflow/sdk/definitions/dag.py	28	21	4
def cleanup() in dev/breeze/src/airflow_breeze/commands/main_command.py	93	21	1
def get_uri() in airflow-core/src/airflow/models/connection.py	45	21	1