deepseek-ai / smallpond - 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 773 units with 5,802 lines of code in units (64.0% of code).

0 very complex units (0 lines of code)
2 complex units (116 lines of code)
22 medium complex units (962 lines of code)
40 simple units (956 lines of code)
709 very simple units (3,768 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 collect_output_files() in smallpond/execution/task.py	62	28	2
def to_duckdb_type() in smallpond/logical/udf.py	54	27	1
def create_exec_plan() in smallpond/logical/planner.py	64	25	3
def exec_loop() in smallpond/execution/executor.py	73	25	2
def dispatch_tasks() in smallpond/execution/scheduler.py	40	22	2
def process_finished_tasks() in smallpond/execution/scheduler.py	69	21	2
def run() in smallpond/execution/task.py	55	19	1
def count_objects() in smallpond/execution/workqueue.py	32	18	4
def dump_output() in smallpond/execution/task.py	68	18	2
def __init__() in smallpond/session.py	83	16	2
def run() in smallpond/execution/scheduler.py	56	16	1
def start_speculative_execution() in smallpond/execution/scheduler.py	36	15	1
def sched_loop() in smallpond/execution/scheduler.py	38	15	2
def finalize() in smallpond/execution/task.py	28	15	1
def finalize() in smallpond/execution/task.py	37	14	1
def visit() in smallpond/logical/node.py	27	13	3
def visit_partition_node() in smallpond/logical/planner.py	61	13	3
def clean_complex_attrs() in smallpond/execution/task.py	20	13	1
def run_on_ray() in smallpond/execution/task.py	50	13	1
def _read_partition_key() in smallpond/logical/dataset.py	29	12	3
def update_state() in smallpond/execution/scheduler.py	29	12	2
def convert_type_to_large() in smallpond/io/arrow.py	25	11	1
def broadcast_input_deps() in smallpond/logical/planner.py	29	11	3
def merge() in smallpond/logical/dataset.py	13	11	1
def clear_cached_executor_lists() in smallpond/execution/scheduler.py	19	10	1
def export_timeline_figs() in smallpond/execution/scheduler.py	73	10	1
def main() in smallpond/execution/task.py	56	10	0
def dump() in smallpond/io/filesystem.py	45	8	4
def resolved_paths() in smallpond/logical/dataset.py	36	8	1
def get_platform() in smallpond/platform/__init__.py	15	8	1
def update_executor_states() in smallpond/execution/scheduler.py	23	8	1
def try_boost_resource() in smallpond/execution/scheduler.py	28	8	3
def export_task_metrics() in smallpond/execution/scheduler.py	34	8	1
def notify_state_observers() in smallpond/execution/scheduler.py	17	8	2
def try_enqueue() in smallpond/execution/scheduler.py	16	8	3
def initialize() in smallpond/execution/task.py	27	8	1
def run() in smallpond/execution/task.py	22	8	1
def _compute() in smallpond/dataframe.py	8	8	1
def main() in benchmarks/gray_sort_benchmark.py	41	7	0
def visit_query_engine_node() in smallpond/logical/optimizer.py	15	7	3
def visit_consolidate_node() in smallpond/logical/planner.py	16	7	3
def collect_finished_works() in smallpond/execution/executor.py	21	7	1
def busy() in smallpond/execution/scheduler.py	7	7	1
def pop() in smallpond/execution/scheduler.py	21	7	1
def probe_executors() in smallpond/execution/scheduler.py	20	7	1
def _pop_unbuffered() in smallpond/execution/workqueue.py	23	7	2
def main() in smallpond/execution/workqueue.py	29	7	0
def _create_empty_file() in smallpond/execution/task.py	39	7	3
def partition() in smallpond/execution/task.py	51	7	3
def _get_or_create_tasks() in smallpond/dataframe.py	18	7	1