id: 1
unit: def main()
file: components/processing/libs/processor-msg/src/processors/msg/run.py
start line: 0
end line: 0
size: 48 LOC
McCabe index: 2
number of parameters: 0

id: 2
unit: def copy()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 42 LOC
McCabe index: 13
number of parameters: 3

id: 3
unit: def choose_related_document()
file: components/webui/src/dpu/components.py
start line: 0
end line: 0
size: 41 LOC
McCabe index: 7
number of parameters: 2

id: 4
unit: def run()
file: components/specialized-parser/src/parser_main.py
start line: 0
end line: 0
size: 36 LOC
McCabe index: 3
number of parameters: 0

id: 5
unit: def _document_to_dict()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 33 LOC
McCabe index: 10
number of parameters: 1

id: 6
unit: def import_docs_to_datastore()
file: components/dpu-workflow/src/utils/datastore_utils.py
start line: 0
end line: 0
size: 33 LOC
McCabe index: 2
number of parameters: 3

id: 7
unit: def choose_source_id()
file: components/webui/src/dpu/components.py
start line: 0
end line: 0
size: 32 LOC
McCabe index: 3
number of parameters: 2

id: 8
unit: def extract_classifier_result()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 32 LOC
McCabe index: 7
number of parameters: 2

id: 9
unit: def lock()
file: tasks.py
start line: 0
end line: 0
size: 32 LOC
McCabe index: 7
number of parameters: 4

id: 10
unit: def call_batch_processor()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 31 LOC
McCabe index: 1
number of parameters: 1

id: 11
unit: def show_agent_document()
file: components/webui/src/dpu/components.py
start line: 0
end line: 0
size: 28 LOC
McCabe index: 5
number of parameters: 1

id: 12
unit: def generate_classify_job_params_fn()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 28 LOC
McCabe index: 3
number of parameters: 1

id: 13
unit: def write_jsonl()
file: components/utils/converter.py
start line: 0
end line: 0
size: 27 LOC
McCabe index: 4
number of parameters: 4

id: 14
unit: def cloud_run_local_deploy()
file: components/processing/tasks.py
start line: 0
end line: 0
size: 27 LOC
McCabe index: 1
number of parameters: 1

id: 15
unit: def xlsx_processor()
file: components/processing/libs/processor-xlsx/src/processors/xlsx/xlsx_processor.py
start line: 0
end line: 0
size: 26 LOC
McCabe index: 6
number of parameters: 2

id: 16
unit: def main()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 26 LOC
McCabe index: 2
number of parameters: 0

id: 17
unit: def run()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 26 LOC
McCabe index: 2
number of parameters: 1

id: 18
unit: def generate_specialized_process_job_params()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 26 LOC
McCabe index: 3
number of parameters: 1

id: 19
unit: def build_bq_metadata_row()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 24 LOC
McCabe index: 1
number of parameters: 2

id: 20
unit: def save()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 22 LOC
McCabe index: 2
number of parameters: 2

id: 21
unit: def write_results_to_bigquery()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 22 LOC
McCabe index: 4
number of parameters: 3

id: 22
unit: def move_duplicated_files_to_rejected_bucket_fn()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 22 LOC
McCabe index: 3
number of parameters: 1

id: 23
unit: def generate_process_job_params()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 21 LOC
McCabe index: 3
number of parameters: 1

id: 24
unit: def __init__()
file: components/processing/libs/processor-xlsx/src/processors/xlsx/xlsx_generator.py
start line: 0
end line: 0
size: 20 LOC
McCabe index: 1
number of parameters: 1

id: 25
unit: def detect_duplicates()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 19 LOC
McCabe index: 5
number of parameters: 2

id: 26
unit: def get_hash()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 17 LOC
McCabe index: 1
number of parameters: 2

id: 27
unit: def crc32c()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 17 LOC
McCabe index: 5
number of parameters: 1

id: 28
unit: def write_folder()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 4
number of parameters: 1

id: 29
unit: def init_connection_pool()
file: components/post-setup-config/src/dbconfig_main.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 1
number of parameters: 1

id: 30
unit: def fetch_agent_doc()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 1
number of parameters: 1

id: 31
unit: def render_embedded()
file: components/webui/src/dpu/components.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 2
number of parameters: 2

id: 32
unit: def move()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 2
number of parameters: 1

id: 33
unit: def init_connection_pool()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 1
number of parameters: 1

id: 34
unit: def drop_data_table()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 5
number of parameters: 2

id: 35
unit: def get_proto_data()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 4
number of parameters: 2

id: 36
unit: def generate_check_duplicated_files_job_params_fn()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 2
number of parameters: 1

id: 37
unit: def generate_mv_params()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 1
number of parameters: 1

id: 38
unit: def look_up_document()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 2
number of parameters: 2

id: 39
unit: def get_mime_type()
file: components/utils/converter.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 10
number of parameters: 1

id: 40
unit: def load_results()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 4
number of parameters: 1

id: 41
unit: def parse_doc_classifier_output()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 1
number of parameters: 1

id: 42
unit: def move_rejected_file()
file: components/processing/libs/processor-msg/src/processors/msg/main_processor.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 1
number of parameters: 3

id: 43
unit: def verify_alloydb_table()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 1
number of parameters: 1

id: 44
unit: def fetch_all_agent_docs()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 3
number of parameters: 0

id: 45
unit: def generate_update_doc_registry_job_params_fn()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 1
number of parameters: 1

id: 46
unit: def delete_gcs_folder()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 3
number of parameters: 2

id: 47
unit: def read_as_obj()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 2
number of parameters: 1

id: 48
unit: def write_as_file()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 2
number of parameters: 1

id: 49
unit: def write_as_obj()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 2
number of parameters: 1

id: 50
unit: def get_sheet()
file: components/processing/libs/processor-xlsx/src/processors/xlsx/xlsx_generator.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 4
number of parameters: 5

id: 51
unit: def msg_to_dict()
file: components/processing/libs/processor-msg/src/processors/msg/msg_processor.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 2
number of parameters: 1

id: 52
unit: def open()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 5
number of parameters: 3

id: 53
unit: def list()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 5
number of parameters: 1

id: 54
unit: def search_service_client()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 2
number of parameters: 0

id: 55
unit: def document_service_client()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 2
number of parameters: 0

id: 56
unit: def local_dev()
file: components/webui/tasks.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 2
number of parameters: 2

id: 57
unit: def get_mv_params()
file: components/dpu-workflow/src/utils/file_utils.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 3
number of parameters: 4

id: 58
unit: def delete_doc_from_gcs()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 3
number of parameters: 2

id: 59
unit: def run_detect_duplicates()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 2
number of parameters: 3

id: 60
unit: def write_text()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 2
number of parameters: 3

id: 61
unit: def write_folder_as_gcs()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 3
number of parameters: 1

id: 62
unit: def write_metadata_to_bigquery()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 3
number of parameters: 2

id: 63
unit: def get_supported_file_types()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 1
number of parameters: 1

id: 64
unit: def delete_doc_from_alloydb_processed_documents()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 1
number of parameters: 1

id: 65
unit: def write_to_folder()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 4

id: 66
unit: def cloud_run_remote_build()
file: components/processing/tasks.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 1

id: 67
unit: def save()
file: components/processing/libs/processor-xlsx/src/processors/xlsx/xlsx_generator.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 4

id: 68
unit: def write_bytes()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 2

id: 69
unit: def read_as_file()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 1

id: 70
unit: def unzip_processor()
file: components/processing/libs/processor-base/src/processors/zip/unzip_processor.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 2

id: 71
unit: def get_bucket_name()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 1

id: 72
unit: def batch_classify_documents()
file: components/doc-classifier/src/doc_classifier_main.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 0

id: 73
unit: def has_files_to_process()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 1

id: 74
unit: def has_files_to_process_after_removing_duplicates_fn()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 2
number of parameters: 1

id: 75
unit: def data_store_import_docs()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 1

id: 76
unit: def struct_data()
file: components/utils/converter.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 1

id: 77
unit: def process()
file: components/processing/tasks.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 78
unit: def __call__()
file: components/processing/libs/processor-msg/src/processors/msg/run.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 9
number of parameters: 7

id: 79
unit: def get_people()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 3

id: 80
unit: def open_bucket()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 2
number of parameters: 2

id: 81
unit: def specialized_parser_job_params()
file: components/dpu-workflow/src/utils/cloud_run_utils.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 82
unit: def is_json()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 2
number of parameters: 1

id: 83
unit: def __init__()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 84
unit: def move_classifier_matched_files()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 85
unit: def extract_common_gcs_folder_from_query_result()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 4
number of parameters: 1

id: 86
unit: def jsonl()
file: components/utils/main.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 0

id: 87
unit: def cleanse_string()
file: components/processing/libs/processor-xlsx/src/processors/xlsx/xlsx_processor.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 88
unit: def __init__()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 2

id: 89
unit: def create_msg_file()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 0

id: 90
unit: def __init__()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 91
unit: def get_attachments()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 3
number of parameters: 1

id: 92
unit: def get_mimetype()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 3
number of parameters: 1

id: 93
unit: def as_gcs_link()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 94
unit: def delete()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 95
unit: def get_process_job_params()
file: components/dpu-workflow/src/utils/cloud_run_utils.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 0

id: 96
unit: def get_doc_classifier_job_overrides()
file: components/dpu-workflow/src/utils/cloud_run_utils.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 0

id: 97
unit: def get_bq_write_stream()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 98
unit: def __init__()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 6

id: 99
unit: def __init__()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 100
unit: def get_bucket()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 101
unit: def get_documents_in_folder()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 4
number of parameters: 1

id: 102
unit: def main()
file: components/utils/main.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 103
unit: def md_to_html()
file: components/utils/converter.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 104
unit: def to_csv()
file: components/utils/converter.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 3
number of parameters: 2

id: 105
unit: def process_all_objects()
file: components/processing/libs/processor-msg/src/processors/msg/main_processor.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 106
unit: def process_object()
file: components/processing/libs/processor-msg/src/processors/msg/main_processor.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 107
unit: def read_text()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 2

id: 108
unit: def read_bytes()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 109
unit: def size()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 110
unit: def is_valid_processor_id()
file: components/specialized-parser/src/parser_main.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 111
unit: def __init__()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 112
unit: def write_results_to_alloydb()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 113
unit: def fetch_gcs_blob()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 2

id: 114
unit: def question_change()
file: components/webui/src/pages/1_Search_Documents.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 115
unit: def get_random_process_folder_name()
file: components/dpu-workflow/src/utils/file_utils.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 116
unit: def is_valid_processor_id()
file: components/dpu-workflow/src/utils/docai_utils.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 117
unit: def delete_doc_from_bq_processed_documents()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 2

id: 118
unit: def delete_doc_from_doc_registry()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 2
number of parameters: 2

id: 119
unit: def blob_to_doc()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 120
unit: def extract_folder_doc_name()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 121
unit: def extract_bucket_and_folder()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 122
unit: def to_bytes()
file: components/processing/libs/processor-xlsx/src/processors/xlsx/xlsx_generator.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 2
number of parameters: 2

id: 123
unit: def to_bytes()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 2
number of parameters: 1

id: 124
unit: def show_gcs_object()
file: components/webui/src/dpu/components.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 125
unit: def get_doc_registry_duplicate_job_override()
file: components/dpu-workflow/src/utils/cloud_run_utils.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 126
unit: def get_doc_registry_update_job_override()
file: components/dpu-workflow/src/utils/cloud_run_utils.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 127
unit: def extract_bucket_and_blob_name()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 128
unit: def is_match()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 3
number of parameters: 3

id: 129
unit: def main()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 130
unit: def get_storage_client()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 131
unit: def get_bq_client()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 132
unit: def extract_bucket_and_blob_name()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 133
unit: def xlsx_to_pdf()
file: components/utils/converter.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 3

id: 134
unit: def generate_document_id()
file: components/utils/converter.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 135
unit: def process_recursive()
file: components/processing/libs/processor-msg/src/processors/msg/main_processor.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 136
unit: def __init__()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 137
unit: def is_gcs()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 138
unit: def exists()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 139
unit: def friendly_path()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 140
unit: def __init__()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 2

id: 141
unit: def get_storage_client()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 142
unit: def get_bucket()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 2

id: 143
unit: def __init__()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 2

id: 144
unit: def transform_docai_entity_to_obj()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 145
unit: def derive_input_blob_name()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 2

id: 146
unit: def get_results()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 147
unit: def move_duplicated_files()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 148
unit: def generate_output_table_name()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 149
unit: def delete_doc_from_agent_build()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 150
unit: def base64_to_int()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 151
unit: def extract_folder_including_bucket_from_blob_uri()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 152
unit: def to_csv_pd()
file: components/utils/converter.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 2

id: 153
unit: def msg_processor()
file: components/processing/libs/processor-msg/src/processors/msg/msg_processor.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 154
unit: def __init__()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 2

id: 155
unit: def read_and_parse_batch_results()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 156
unit: def divide_chunks()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 3

id: 157
unit: def generate_answer()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 158
unit: def update_preamble()
file: components/webui/src/pages/1_Search_Documents.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 159
unit: def generate_process_folder()
file: components/dpu-workflow/src/docs_processing_orchestrator.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 160
unit: def get_json_str()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 161
unit: def __str__()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 162
unit: def get_gcs_name()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 2
number of parameters: 1

id: 163
unit: def get_gcs_uri()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 164
unit: def add_new_documents_to_registry()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 165
unit: def input_rows_to_document_info()
file: components/doc-registry/src/document_registry_service.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 166
unit: def cloud_run_execute()
file: components/processing/tasks.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 167
unit: def get_person()
file: components/processing/libs/processor-msg/src/processors/msg/msg_generator.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 168
unit: def reject_oversized_file()
file: components/processing/libs/processor-msg/src/processors/msg/main_processor.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 169
unit: def GCS_TMP_PREFIX()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 170
unit: def move()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 171
unit: def __str__()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 172
unit: def __hash__()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 173
unit: def __eq__()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 174
unit: def hash()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 175
unit: def suffix()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 176
unit: def name()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 177
unit: def mimetype()
file: components/processing/libs/processor-base/src/processors/base/gcsio.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 178
unit: def create_connection_pool()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 179
unit: def getconn()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 180
unit: def wait_for_completion_and_verify_success()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 181
unit: def write_results_to_gcs()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 182
unit: def write_results_to_alloydb_with_inserts()
file: components/specialized-parser/src/runner.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 183
unit: def get_storage_client()
file: components/webui/src/dpu/api.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 184
unit: def supported_files_by_type()
file: components/dpu-workflow/src/utils/file_utils.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 185
unit: def __build_gcs_path__()
file: components/dpu-workflow/src/utils/cloud_run_utils.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 3

id: 186
unit: def get_doc_name()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 187
unit: def get_doc_type()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 188
unit: def __init__()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 189
unit: def __str__()
file: components/dpu-workflow/src/utils/gcs_utils.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 190
unit: def get_docs_data_from_bq()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 191
unit: def delete_doc_from_metadata_table()
file: components/doc-deletion/src/doc_deletion_main.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 192
unit: def sync()
file: tasks.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 3