netflix / metaflow - 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 2,894 units with 32,726 lines of code in units (63.2% of code).

5 very complex units (1,602 lines of code)
20 complex units (2,887 lines of code)
134 medium complex units (6,177 lines of code)
255 simple units (6,102 lines of code)
2,480 very simple units (15,958 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 _container_templates() in metaflow/plugins/argo/argo_workflows.py	695	118	1
def _get_extension_packages() in metaflow/extension_support/__init__.py	385	70	2
def worker() in metaflow/plugins/datatools/s3/s3op.py	173	54	4
def __init__() in metaflow/plugins/env_escape/server.py	162	53	3
def _s3op_with_retries() in metaflow/plugins/datatools/s3/s3.py	187	51	3
def _batch() in metaflow/plugins/aws/step_functions/step_functions.py	210	48	2
def init() in metaflow/plugins/kubernetes/kubernetes_decorator.py	98	48	1
def _generate_class_stub() in metaflow/cmd/develop/stub_generator.py	287	48	3
def _dag_templates() in metaflow/plugins/argo/argo_workflows.py	314	42	1
def init_environment() in metaflow/plugins/pypi/conda_environment.py	110	41	3
def get_environment() in metaflow/plugins/pypi/conda_environment.py	77	41	2
def step_init() in metaflow/plugins/kubernetes/kubernetes_decorator.py	97	40	8
def _compile_sensor() in metaflow/plugins/argo/argo_workflows.py	244	40	1
def inner_init() in metaflow/plugins/env_escape/client.py	145	38	5
def _transform_container() in metaflow/plugins/env_escape/data_transferer.py	82	33	6
def _process_triggers() in metaflow/plugins/argo/argo_workflows.py	102	33	1
def write_out() in metaflow/cmd/develop/stub_generator.py	96	33	1
def clone_original_run() in metaflow/runtime.py	97	32	3
def format_deploytime_value() in metaflow/plugins/events_decorator.py	85	32	1
def execute() in metaflow/runtime.py	102	31	1
def _to_job() in metaflow/plugins/airflow/airflow.py	192	31	2
def create_job_spec() in metaflow/plugins/kubernetes/kubernetes_job.py	187	31	1
def find_spec() in metaflow/extension_support/__init__.py	69	29	4
def _compile() in metaflow/plugins/aws/step_functions/step_functions.py	136	28	1
def render() in metaflow/plugins/cards/card_modules/basic.py	157	27	1
def compile() in metaflow/plugins/airflow/airflow.py	83	25	1
def _compile_workflow_template() in metaflow/plugins/argo/argo_workflows.py	204	25	1
def _heartbeat_daemon_template() in metaflow/plugins/argo/argo_workflows.py	128	25	1
def get_version() in metaflow/metaflow_version.py	35	24	1
def process_integration_aliases() in metaflow/extension_support/integrations.py	64	23	1
def process_plugins() in metaflow/extension_support/plugins.py	46	23	1
def get_secret_as_dict() in metaflow/plugins/azure/azure_secret_manager_secrets_provider.py	39	23	4
def _step_cli() in metaflow/plugins/aws/step_functions/step_functions.py	90	22	5
def _set_constants() in metaflow/flowspec.py	52	22	4
def compile() in metaflow/plugins/airflow/airflow_utils.py	37	21	1
def _construct_jobset_logical_status() in metaflow/plugins/kubernetes/kubernetes_jobsets.py	85	21	2
def dump() in metaflow/plugins/kubernetes/kubernetes_jobsets.py	215	21	1
def _get_module() in metaflow/cmd/develop/stub_generator.py	84	21	3
def wait() in metaflow/plugins/aws/batch/batch.py	85	20	4
def get_secret_as_dict() in metaflow/plugins/aws/secrets_manager/aws_secrets_manager_secrets_provider.py	72	20	4
def download() in metaflow/plugins/pypi/pip.py	90	20	5
def process_parameters() in metaflow/plugins/events_decorator.py	42	20	2
def _finalize() in metaflow/plugins/cards/component_serializer.py	51	20	1
def load_module() in metaflow/plugins/env_escape/client_modules.py	50	19	2
def _compute_flow_parameters() in metaflow/runner/click_api.py	65	19	1
def next() in metaflow/flowspec.py	106	19	4
def dict_to_cli_options() in metaflow/util.py	24	18	1
def _get_extension_config() in metaflow/extension_support/__init__.py	25	18	4
def _queue_task_join() in metaflow/runtime.py	97	18	3
def resolve_delayed_evaluator() in metaflow/user_configs/config_parameters.py	20	18	2