def execute_pipeline()

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

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

def execute_pipeline(
    source_url: str,
    source_file: pathlib.Path,
    target_file: pathlib.Path,
    chunksize: str,
    project_id: str,
    dataset_id: str,
    destination_table: str,
    target_gcs_bucket: str,
    target_gcs_path: str,
    schema_path: str,
    drop_dest_table: str,
    truncate_table: bool,
    input_field_delimiter: str,
    remove_source_file: str,
    delete_target_file: str,
    input_csv_headers: typing.List[str],
    data_dtypes: dict,
    output_csv_headers: typing.List[str],
    rename_headers_list: dict,
    table_description: str,
    file_name_prefix: str,