GoogleCloudPlatform / gcs-connector-for-pytorch

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 80 units with 1,124 lines of code in units (54.6% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
3 medium complex units (258 lines of code)
5 simple units (159 lines of code)
72 very simple units (707 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 main() in dataflux_pytorch/benchmark/checkpointing/singlenode/train.py	73	21	0
def main() in dataflux_pytorch/benchmark/checkpointing/multinode/train.py	88	12	2
def data_load_loop() in dataflux_pytorch/benchmark/standalone_dataloader/standalone_dataloader.py	97	11	1
def validate() in dataflux_pytorch/benchmark/checkpointing/multinode/train.py	15	9	1
def get_strategy() in dataflux_pytorch/benchmark/checkpointing/multinode/train.py	40	8	2
def parse_gcs_path() in dataflux_pytorch/lightning/path_utils.py	20	8	2
def __iter__() in dataflux_pytorch/benchmark/standalone_dataloader/standalone_dataloader.py	42	7	1
def run_benchmark() in dataflux_pytorch/benchmark/checkpointing/simulated/llama2.py	42	6	7
def _get_missing_permissions() in dataflux_pytorch/_helper.py	13	5	4
def configure_master_addr() in dataflux_pytorch/benchmark/checkpointing/simulated/benchmark.py	21	5	0
def run_benchmark() in dataflux_pytorch/benchmark/checkpointing/simulated/benchmark.py	43	5	7
def configure_master_addr() in dataflux_pytorch/benchmark/checkpointing/simulated/llama2.py	21	5	0
def create_stream() in dataflux_pytorch/lightning/gcs_filesystem.py	24	5	4
def __getitems__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	16	4	2
def _list_GCS_blobs_with_retry() in dataflux_pytorch/dataflux_mapstyle_dataset.py	25	4	1
def __iter__() in dataflux_pytorch/dataflux_iterable_dataset.py	29	4	1
def _list_GCS_blobs_with_retry() in dataflux_pytorch/dataflux_iterable_dataset.py	25	4	1
def main() in dataflux_pytorch/benchmark/checkpointing/multinode/train_async_save.py	76	4	0
def process_input_path() in dataflux_pytorch/lightning/path_utils.py	9	4	2
def _prepare_upload_request() in dataflux_pytorch/multipart_upload/multipart.py	13	3	1
def print_times() in dataflux_pytorch/benchmark/checkpointing/multinode/train.py	11	3	3
def validate_checkpoint_id() in dataflux_pytorch/lightning/gcs_filesystem.py	6	3	3
def __getitem__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	10	2	2
def forward() in dataflux_pytorch/benchmark/checkpointing/multinode/train_async_save.py	3	2	3
def copy_bucket_to_local() in dataflux_pytorch/benchmark/checkpointing/multinode/train.py	8	2	2
def main() in dataflux_pytorch/benchmark/standalone_dataloader/standalone_dataloader.py	11	2	1
def concat_path() in dataflux_pytorch/lightning/gcs_filesystem.py	5	2	4
def init_path() in dataflux_pytorch/lightning/gcs_filesystem.py	5	2	3
def rename() in dataflux_pytorch/lightning/gcs_filesystem.py	10	2	5
def teardown() in dataflux_pytorch/lightning/dataflux_lightning_checkpoint.py	4	2	1
def __init__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	13	1	4
def data_format_default() in dataflux_pytorch/dataflux_mapstyle_dataset.py	2	1	1
def __init__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	7	1	4
def __len__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	2	1	1
def __getstate__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	4	1	1
def __setstate__() in dataflux_pytorch/dataflux_mapstyle_dataset.py	3	1	2
def __init__() in dataflux_pytorch/dataflux_iterable_dataset.py	12	1	4
def data_format_default() in dataflux_pytorch/dataflux_iterable_dataset.py	2	1	1
def __init__() in dataflux_pytorch/dataflux_iterable_dataset.py	7	1	4
def upload_chunks_concurrently_from_bytesio() in dataflux_pytorch/multipart_upload/multipart.py	11	1	0
def __init__() in dataflux_pytorch/multipart_upload/multipart.py	10	1	0
def _buffer_view_upload_part() in dataflux_pytorch/multipart_upload/multipart.py	11	1	0
def __init__() in dataflux_pytorch/dataflux_checkpoint.py	5	1	0
def reader() in dataflux_pytorch/dataflux_checkpoint.py	6	1	2
def writer() in dataflux_pytorch/dataflux_checkpoint.py	3	1	2
def __init__() in dataflux_pytorch/dataflux_checkpoint.py	3	1	2
def close() in dataflux_pytorch/dataflux_checkpoint.py	3	1	1
def init_processes() in dataflux_pytorch/benchmark/checkpointing/simulated/benchmark.py	11	1	0
def main() in dataflux_pytorch/benchmark/checkpointing/simulated/benchmark.py	11	1	0
def init_processes() in dataflux_pytorch/benchmark/checkpointing/simulated/llama2.py	11	1	0