def execute_pipeline()

in datasets/san_francisco/pipelines/_images/run_csv_transform_kub/csv_transform.py [0:0]

• 33 lines of code
• 1 McCabe index (conditional complexity)

def execute_pipeline(
    source_url: str,
    source_url_dict: dict,
    source_url_list: typing.List[str],
    source_file: pathlib.Path,
    target_file: pathlib.Path,
    project_id: str,
    dataset_id: str,
    destination_table: str,
    drop_dest_table: str,
    schema_path: str,
    chunksize: str,
    header_row_ordinal: str,
    target_gcs_bucket: str,
    target_gcs_path: str,
    input_headers: typing.List[str],
    data_dtypes: dict,
    trip_data_names: typing.List[str],
    trip_data_dtypes: dict,
    tripdata_names: typing.List[str],
    tripdata_dtypes: dict,
    rename_headers_tripdata: dict,
    rename_headers_list: typing.List[str],
    starts_with_pattern_list: typing.List[str],
    empty_key_list: typing.List[str],
    gen_location_list: dict,
    resolve_datatypes_list: dict,
    remove_paren_list: typing.List[str],
    strip_newlines_list: typing.List[str],
    strip_whitespace_list: typing.List[str],
    date_format_list: dict,
    filter_headers_list: typing.List[str],
    reorder_headers_list: typing.List[str],