id: 1
unit: def longitudinal_shim_transform()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 88 LOC
McCabe index: 15
number of parameters: 3

id: 2
unit: def create_cluster()
file: utils/dataproc.py
start line: 0
end line: 0
size: 76 LOC
McCabe index: 11
number of parameters: 1

id: 3
unit: def create_jira_ticket()
file: dags/eam_workday_everfi_integration.py
start line: 0
end line: 0
size: 68 LOC
McCabe index: 2
number of parameters: 1

id: 4
unit: def create_jira_ticket()
file: dags/eam_workday_netsuite.py
start line: 0
end line: 0
size: 68 LOC
McCabe index: 2
number of parameters: 1

id: 5
unit: def create_jira_ticket()
file: dags/eam_slack_channels.py
start line: 0
end line: 0
size: 68 LOC
McCabe index: 2
number of parameters: 1

id: 6
unit: def bqetl_backfill_dag()
file: dags/bqetl_backfill.py
start line: 0
end line: 0
size: 51 LOC
McCabe index: 11
number of parameters: 0

id: 7
unit: def initiate_backfill()
file: dags/bqetl_backfill_initiate.py
start line: 0
end line: 0
size: 50 LOC
McCabe index: 3
number of parameters: 1

id: 8
unit: def complete_backfill()
file: dags/bqetl_backfill_complete.py
start line: 0
end line: 0
size: 43 LOC
McCabe index: 3
number of parameters: 1

id: 9
unit: def backfill_dag()
file: dags/backfill.py
start line: 0
end line: 0
size: 41 LOC
McCabe index: 1
number of parameters: 0

id: 10
unit: def moz_dataproc_pyspark_runner()
file: utils/dataproc.py
start line: 0
end line: 0
size: 35 LOC
McCabe index: 1
number of parameters: 0

id: 11
unit: def has_min_update_ping_count_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 34 LOC
McCabe index: 18
number of parameters: 1

id: 12
unit: def moz_dataproc_jar_runner()
file: utils/dataproc.py
start line: 0
end line: 0
size: 32 LOC
McCabe index: 1
number of parameters: 0

id: 13
unit: def moz_dataproc_scriptrunner()
file: utils/dataproc.py
start line: 0
end line: 0
size: 32 LOC
McCabe index: 1
number of parameters: 0

id: 14
unit: def __init__()
file: utils/dataproc.py
start line: 0
end line: 0
size: 31 LOC
McCabe index: 1
number of parameters: 0

id: 15
unit: def get_dataproc_parameters()
file: utils/dataproc.py
start line: 0
end line: 0
size: 30 LOC
McCabe index: 6
number of parameters: 1

id: 16
unit: def get_rows()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 30 LOC
McCabe index: 13
number of parameters: 1

id: 17
unit: def state_code_stage_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 29 LOC
McCabe index: 14
number of parameters: 1

id: 18
unit: def state_failure_code_stage_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 29 LOC
McCabe index: 14
number of parameters: 1

id: 19
unit: def state_code_startup_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 29 LOC
McCabe index: 14
number of parameters: 1

id: 20
unit: def state_failure_code_startup_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 29 LOC
McCabe index: 14
number of parameters: 1

id: 21
unit: def parse_args()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 27 LOC
McCabe index: 1
number of parameters: 0

id: 22
unit: def train_metric()
file: jobs/ltv_daily.py
start line: 0
end line: 0
size: 25 LOC
McCabe index: 2
number of parameters: 4

id: 23
unit: def process_pod_deletion()
file: operators/gcp_container_operator.py
start line: 0
end line: 0
size: 24 LOC
McCabe index: 7
number of parameters: 4

id: 24
unit: def operational_monitoring_backfill_dag()
file: dags/operational_monitoring_backfill.py
start line: 0
end line: 0
size: 22 LOC
McCabe index: 2
number of parameters: 0

id: 25
unit: def generate_backfill_command()
file: utils/backfill.py
start line: 0
end line: 0
size: 21 LOC
McCabe index: 6
number of parameters: 1

id: 26
unit: def has_min_subsession_length_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 21 LOC
McCabe index: 7
number of parameters: 1

id: 27
unit: def download_code_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 21 LOC
McCabe index: 10
number of parameters: 1

id: 28
unit: def base_backfill_operator()
file: dags/shredder_backfill.py
start line: 0
end line: 0
size: 20 LOC
McCabe index: 3
number of parameters: 1

id: 29
unit: def bigquery_etl_query()
file: utils/gcp.py
start line: 0
end line: 0
size: 19 LOC
McCabe index: 1
number of parameters: 3

id: 30
unit: def check_code_notify_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 19 LOC
McCabe index: 10
number of parameters: 1

id: 31
unit: def retrieve_jar()
file: jobs/telemetry_batch_view.py
start line: 0
end line: 0
size: 19 LOC
McCabe index: 4
number of parameters: 0

id: 32
unit: def longitudinal_shim_aggregate()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 18 LOC
McCabe index: 2
number of parameters: 5

id: 33
unit: def bigquery_etl_copy_deduplicate()
file: utils/gcp.py
start line: 0
end line: 0
size: 17 LOC
McCabe index: 1
number of parameters: 3

id: 34
unit: def parse_args()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 17 LOC
McCabe index: 1
number of parameters: 0

id: 35
unit: def is_supported_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 17 LOC
McCabe index: 12
number of parameters: 1

id: 36
unit: def fetch_schema()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 17 LOC
McCabe index: 2
number of parameters: 0

id: 37
unit: def bigquery_dq_check()
file: utils/gcp.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 1
number of parameters: 4

id: 38
unit: def bigquery_xcom_query()
file: utils/gcp.py
start line: 0
end line: 0
size: 16 LOC
McCabe index: 1
number of parameters: 4

id: 39
unit: def export_to_parquet()
file: utils/gcp.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 1
number of parameters: 0

id: 40
unit: def check_ex_error_notify_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 8
number of parameters: 1

id: 41
unit: def has_no_download_code_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 9
number of parameters: 1

id: 42
unit: def replace_definitions()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 6
number of parameters: 2

id: 43
unit: def __init__()
file: operators/gcp_container_operator.py
start line: 0
end line: 0
size: 15 LOC
McCabe index: 1
number of parameters: 0

id: 44
unit: def repeated_subdag()
file: utils/glam_subdags/general.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 1
number of parameters: 0

id: 45
unit: def is_able_to_apply_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 9
number of parameters: 1

id: 46
unit: def has_update_enabled_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 12
number of parameters: 1

id: 47
unit: def submit_job()
file: jobs/telemetry_batch_view.py
start line: 0
end line: 0
size: 14 LOC
McCabe index: 7
number of parameters: 0

id: 48
unit: def update_cluster()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 1
number of parameters: 0

id: 49
unit: def generate_and_run_desktop_query()
file: utils/glam_subdags/generate_query.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 1
number of parameters: 0

id: 50
unit: def generate_and_run_glean_task()
file: utils/glam_subdags/generate_query.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 1
number of parameters: 0

id: 51
unit: def has_update_apply_failure_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 13 LOC
McCabe index: 7
number of parameters: 1

id: 52
unit: def retry_tasks_callback()
file: utils/callbacks.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 5
number of parameters: 2

id: 53
unit: def bigquery_bigeye_check()
file: utils/gcp.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 1
number of parameters: 0

id: 54
unit: def instantiate_workflow_template()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 1
number of parameters: 0

id: 55
unit: def has_only_no_update_found_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 12 LOC
McCabe index: 11
number of parameters: 1

id: 56
unit: def create_cluster()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 1
number of parameters: 0

id: 57
unit: def histogram_aggregates_subdag()
file: utils/glam_subdags/histograms.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 1
number of parameters: 0

id: 58
unit: def main()
file: jobs/ltv_daily.py
start line: 0
end line: 0
size: 11 LOC
McCabe index: 1
number of parameters: 0

id: 59
unit: def delete_cluster()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 1
number of parameters: 0

id: 60
unit: def instantiate_inline_workflow_template()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 1
number of parameters: 0

id: 61
unit: def submit_job()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 1
number of parameters: 0

id: 62
unit: def has_out_of_date_max_version_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 5
number of parameters: 1

id: 63
unit: def ltv_prob_alive()
file: jobs/ltv_daily.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 3
number of parameters: 1

id: 64
unit: def get_airflow_version()
file: plugins/version_endpoint.py
start line: 0
end line: 0
size: 10 LOC
McCabe index: 3
number of parameters: 0

id: 65
unit: def list_clusters()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 0

id: 66
unit: def create_workflow_template()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 0

id: 67
unit: def get_job()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 0

id: 68
unit: def cancel_job()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 0

id: 69
unit: def generate_and_run_glean_queries()
file: utils/glam_subdags/generate_query.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 1
number of parameters: 0

id: 70
unit: def latest_version_on_date()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 5
number of parameters: 2

id: 71
unit: def get_dockerflow_version()
file: plugins/version_endpoint.py
start line: 0
end line: 0
size: 9 LOC
McCabe index: 3
number of parameters: 0

id: 72
unit: def delete_cluster()
file: utils/dataproc.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 1

id: 73
unit: def validate_regex_pattern()
file: utils/backfill.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 3
number of parameters: 1

id: 74
unit: def __getattr__()
file: utils/tags.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 3
number of parameters: 2

id: 75
unit: def diagnose_cluster()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 0

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

id: 77
unit: def wait_for_job()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 78
unit: def merge_params()
file: utils/glam_subdags/general.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 2
number of parameters: 3

id: 79
unit: def choose_branch()
file: dags/probe_scraper.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 3
number of parameters: 2

id: 80
unit: def backfill()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 8 LOC
McCabe index: 3
number of parameters: 3

id: 81
unit: def validate_date_range()
file: utils/backfill.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 82
unit: def __init__()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 0

id: 83
unit: def set_main()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 4
number of parameters: 3

id: 84
unit: def get_airflow_log_link()
file: dags/eam_workday_everfi_integration.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 1

id: 85
unit: def get_airflow_log_link()
file: dags/eam_workday_netsuite.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 1

id: 86
unit: def clear_branch_callable()
file: dags/backfill.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 87
unit: def get_airflow_log_link()
file: dags/eam_slack_channels.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 1
number of parameters: 1

id: 88
unit: def has_update_ping_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 4
number of parameters: 1

id: 89
unit: def create_struct()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 90
unit: def ltv_predict()
file: jobs/ltv_daily.py
start line: 0
end line: 0
size: 7 LOC
McCabe index: 2
number of parameters: 5

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

id: 92
unit: def submit()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 93
unit: def param_validation()
file: dags/backfill.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 1

id: 94
unit: def import_day()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 6 LOC
McCabe index: 1
number of parameters: 6

id: 95
unit: def normalize_table_id()
file: utils/gcp.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 2
number of parameters: 1

id: 96
unit: def call_exit_errors()
file: jobs/telemetry_batch_view.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 2
number of parameters: 1

id: 97
unit: def ltv_predict_metric()
file: jobs/ltv_daily.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 2

id: 98
unit: def next_dagrun_info()
file: plugins/timetable.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 99
unit: def get_or_create_pod()
file: operators/gcp_container_operator.py
start line: 0
end line: 0
size: 5 LOC
McCabe index: 1
number of parameters: 3

id: 100
unit: def copy_artifacts_dev()
file: utils/dataproc.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 4

id: 101
unit: def should_run_deployment()
file: dags/bqetl_artifact_deployment.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 2

id: 102
unit: def validate_dag_exists()
file: dags/backfill.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 103
unit: def catch_none()
file: jobs/ltv_daily.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 104
unit: def __init__()
file: plugins/timetable.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 2
number of parameters: 4

id: 105
unit: def parse_airflow_version()
file: plugins/version_endpoint.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 106
unit: def version_endpoint()
file: plugins/version_endpoint.py
start line: 0
end line: 0
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 107
unit: def add_labels()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 108
unit: def add_variables()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 109
unit: def add_args()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 110
unit: def add_jar_file_uris()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 111
unit: def add_archive_uris()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 112
unit: def add_file_uris()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 113
unit: def add_python_file_uris()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 114
unit: def dry_run_branch_callable()
file: dags/backfill.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 1

id: 115
unit: def generate_bash_command()
file: dags/backfill.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 116
unit: def by_version_mapper()
file: jobs/update_orphaning_dashboard_etl.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 117
unit: def daterange()
file: jobs/socorro_import_crash_data.py
start line: 0
end line: 0
size: 3 LOC
McCabe index: 2
number of parameters: 2

id: 118
unit: def _format_envvar()
file: utils/dataproc.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 4
number of parameters: 1

id: 119
unit: def add_query()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 120
unit: def add_query_uri()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 121
unit: def set_python_main()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 122
unit: def set_job_name()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 123
unit: def build()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 124
unit: def get_cluster_client()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 125
unit: def get_template_client()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 126
unit: def get_job_client()
file: utils/patched/dataproc_hook.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 127
unit: def merino_job()
file: dags/merino_jobs.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 128
unit: def infer_manual_data_interval()
file: plugins/timetable.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 2

id: 129
unit: def serialize()
file: plugins/timetable.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 130
unit: def deserialize()
file: plugins/timetable.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 3

id: 131
unit: def get_project_root()
file: plugins/version_endpoint.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0

id: 132
unit: def on_pod_completion()
file: operators/gcp_container_operator.py
start line: 0
end line: 0
size: 2 LOC
McCabe index: 1
number of parameters: 0