@flow(flow_run_name=generate_flow_name)
async def flow(
    client_id: int,
    remote_folder: str,
    ftp_conn_str_block: str,
    pgp_key_id: str,
    runtime_config: Optional[RuntimeConfig] = None,
):
    data = get_data()

    format_kwargs = get_string_format_variables()
    save_dir = SAVE_FOLDER.format(**format_kwargs)  # type: ignore

    conn_str = get_client_conn_str(client_id)

    output_files = []
    for query_key, query in data["queries"].items():
        columns = data["columns"][query_key]
        filename = data["files"][query_key]["filename"]
        result = await query_data.submit(conn_str, query, filename)  # type: ignore
        result = await clean_data.submit(result, columns, filename)  # type: ignore
        output_file = await save_file.submit(result, save_dir, filename)  # type: ignore
        output_files.append(output_file)

    process_and_upload_files.submit(save_dir, output_files, pgp_key_id, ftp_conn_str_block, remote_folder)