def execute_pipeline()

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

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

def execute_pipeline(
    source_url: str,
    source_url_stations_json: str,
    source_url_status_json: str,
    source_file: pathlib.Path,
    target_file: pathlib.Path,
    project_id: str,
    dataset_id: str,
    destination_table: str,
    chunksize: str,
    target_gcs_bucket: str,
    target_gcs_path: str,
    schema_path: str,
    transform_list: typing.List[str],
    data_dtypes: typing.List[str],
    parse_dates_list: dict,
    null_rows_list: typing.List[str],
    rename_headers_list: dict,
    output_headers_list: typing.List[str],
    datetime_fieldlist: typing.List[str],
    resolve_datatypes_list: dict,
    reorder_headers_list: typing.List[str],
    regex_list: typing.List[typing.List],
    crash_field_list: typing.List[typing.List],
    date_format_list: typing.List[typing.List],
    normalize_data_list: typing.List[str],
    boolean_datapoints_list: typing.List[str],
    remove_whitespace_list: typing.List[str],