Skip to content

Instantly share code, notes, and snippets.

@taljaards

taljaards/Logs from Prefect UI.txt Secret

Last active February 2, 2023 15:19
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save taljaards/ac26a176d7fc865ea411b64e80b88ec1 to your computer and use it in GitHub Desktop.
Save taljaards/ac26a176d7fc865ea411b64e80b88ec1 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
flow_run_logs.json
[
{
"id": "48b479a8-d095-42ae-b28d-180bdcd0cc26",
"created": "2023-02-02T14:35:04.043060+00:00",
"updated": "2023-02-02T14:35:04.043060+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Downloading flow code from storage at 'LoadTest_load_test_testdeployment4'",
"timestamp": "2023-02-02T14:34:16.598117+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "65f4d77c-0e13-4de5-944f-948c9e78b100",
"created": "2023-02-02T14:35:04.043451+00:00",
"updated": "2023-02-02T14:35:04.043451+00:00",
"name": "prefect.flow_runs",
"level": 10,
"message": "Importing flow code from 'load_test.py:main'",
"timestamp": "2023-02-02T14:34:17.082057+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "2ec24d6a-0b05-4dd5-b3b3-6850da6cf92c",
"created": "2023-02-02T14:35:04.043818+00:00",
"updated": "2023-02-02T14:35:04.043818+00:00",
"name": "prefect.flow_runs",
"level": 10,
"message": "Starting 'ConcurrentTaskRunner'; submitted tasks will be run concurrently...",
"timestamp": "2023-02-02T14:34:17.818923+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "1d273623-ba0a-4622-a2af-150be146e853",
"created": "2023-02-02T14:36:53.106444+00:00",
"updated": "2023-02-02T14:36:53.106444+00:00",
"name": "prefect.flow_runs",
"level": 10,
"message": "Executing flow 'Load test' for flow run 'white-hound'...",
"timestamp": "2023-02-02T14:34:18.784059+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "680b7c53-9b69-4675-be96-e9d15360eee0",
"created": "2023-02-02T14:36:53.106934+00:00",
"updated": "2023-02-02T14:36:53.106934+00:00",
"name": "prefect.flow_runs",
"level": 10,
"message": "Beginning execution...",
"timestamp": "2023-02-02T14:34:18.786320+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "b47ef6a1-e366-420f-9d27-9f30ae6a2740",
"created": "2023-02-02T14:36:53.107392+00:00",
"updated": "2023-02-02T14:36:53.107392+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Created task run 'generate_duration-cf5a2355-0' for task 'generate_duration'",
"timestamp": "2023-02-02T14:34:18.971762+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "7adf4686-7a3b-4d7d-a05e-aafdecb29000",
"created": "2023-02-02T14:36:53.107846+00:00",
"updated": "2023-02-02T14:36:53.107846+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Executing 'generate_duration-cf5a2355-0' immediately...",
"timestamp": "2023-02-02T14:34:18.973265+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6a7b65c5-2acc-4dd9-b551-0134215cd5ea",
"created": "2023-02-02T14:36:53.108299+00:00",
"updated": "2023-02-02T14:36:53.108299+00:00",
"name": "prefect.task_runs",
"level": 10,
"message": "Beginning execution...",
"timestamp": "2023-02-02T14:34:19.473199+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "45ce466c-17bb-4a35-b4a7-3dfc61fd7697"
},
{
"id": "1b63be5f-a49c-44e5-af52-8c7aa275434a",
"created": "2023-02-02T14:36:53.108688+00:00",
"updated": "2023-02-02T14:36:53.108688+00:00",
"name": "prefect.task_runs",
"level": 20,
"message": "24",
"timestamp": "2023-02-02T14:34:19.475196+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "45ce466c-17bb-4a35-b4a7-3dfc61fd7697"
},
{
"id": "72843375-8223-44d2-b3d7-4534bfb3bfb7",
"created": "2023-02-02T14:36:53.109034+00:00",
"updated": "2023-02-02T14:36:53.109034+00:00",
"name": "prefect.task_runs",
"level": 20,
"message": "Finished in state Completed()",
"timestamp": "2023-02-02T14:34:19.965629+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "45ce466c-17bb-4a35-b4a7-3dfc61fd7697"
},
{
"id": "059d691f-06da-45f0-8375-d3f9fbf25766",
"created": "2023-02-02T14:36:53.109305+00:00",
"updated": "2023-02-02T14:36:53.109305+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Created task run 'simulate_etl-390a3f7f-0' for task 'simulate_etl'",
"timestamp": "2023-02-02T14:34:20.139093+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "dd969931-24eb-4119-81d1-0a4cbc1a084e",
"created": "2023-02-02T14:36:53.109597+00:00",
"updated": "2023-02-02T14:36:53.109597+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Executing 'simulate_etl-390a3f7f-0' immediately...",
"timestamp": "2023-02-02T14:34:20.140727+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "f9225b53-147d-4bd7-b754-ef049dc9f46f",
"created": "2023-02-02T14:36:53.109969+00:00",
"updated": "2023-02-02T14:36:53.109969+00:00",
"name": "prefect.task_runs",
"level": 10,
"message": "Beginning execution...",
"timestamp": "2023-02-02T14:34:20.775482+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "0bde5e85-e48e-47b6-9ff1-d91ad17ac53f"
},
{
"id": "0d191374-933e-426f-879a-53794e5f2c80",
"created": "2023-02-02T14:36:53.110310+00:00",
"updated": "2023-02-02T14:36:53.110310+00:00",
"name": "prefect.task_runs",
"level": 20,
"message": "Finished in state Completed()",
"timestamp": "2023-02-02T14:34:44.968253+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "0bde5e85-e48e-47b6-9ff1-d91ad17ac53f"
},
{
"id": "7d2faa1e-dcf9-4afa-ae5b-dbf2dbfb7dbe",
"created": "2023-02-02T14:36:53.110731+00:00",
"updated": "2023-02-02T14:36:53.110731+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Created task run 'get_project_dir_name-164c1a9b-0' for task 'get_project_dir_name'",
"timestamp": "2023-02-02T14:34:45.147131+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "2810b44f-46d7-4754-9d0a-2b3a8451ae02",
"created": "2023-02-02T14:36:53.111150+00:00",
"updated": "2023-02-02T14:36:53.111150+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Executing 'get_project_dir_name-164c1a9b-0' immediately...",
"timestamp": "2023-02-02T14:34:45.148375+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "44b9b241-9020-49bd-9664-f42b977da42c",
"created": "2023-02-02T14:36:53.111474+00:00",
"updated": "2023-02-02T14:36:53.111474+00:00",
"name": "prefect.task_runs",
"level": 10,
"message": "Beginning execution...",
"timestamp": "2023-02-02T14:34:45.629199+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "30f8e7df-9cfb-46ed-89cb-29d9737c3781"
},
{
"id": "178c1f94-6f49-4e78-b049-ea8c486f14a5",
"created": "2023-02-02T14:36:53.111844+00:00",
"updated": "2023-02-02T14:36:53.111844+00:00",
"name": "prefect.task_runs",
"level": 20,
"message": "Finished in state Completed()",
"timestamp": "2023-02-02T14:34:53.539993+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "30f8e7df-9cfb-46ed-89cb-29d9737c3781"
},
{
"id": "0e35aafe-d95b-4d4e-b639-99a641df6aa4",
"created": "2023-02-02T14:36:53.112127+00:00",
"updated": "2023-02-02T14:36:53.112127+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Created task run 'generate_unique_file_name-2596364c-0' for task 'generate_unique_file_name'",
"timestamp": "2023-02-02T14:34:53.746773+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "53e64daf-89b1-4aef-b2e3-8fa2d663bc69",
"created": "2023-02-02T14:36:53.112376+00:00",
"updated": "2023-02-02T14:36:53.112376+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Executing 'generate_unique_file_name-2596364c-0' immediately...",
"timestamp": "2023-02-02T14:34:53.748017+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "bcda1699-334e-4db9-b073-60a2a14750b1",
"created": "2023-02-02T14:36:53.112715+00:00",
"updated": "2023-02-02T14:36:53.112715+00:00",
"name": "prefect.task_runs",
"level": 10,
"message": "Beginning execution...",
"timestamp": "2023-02-02T14:34:54.162336+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "f3ee56c5-7e4e-4f41-8b07-73b919a0e0af"
},
{
"id": "cdca6c83-0283-43a1-bcdf-d212fd7e47b2",
"created": "2023-02-02T14:36:58.415219+00:00",
"updated": "2023-02-02T14:36:58.415219+00:00",
"name": "prefect.task_runs",
"level": 40,
"message": "Encountered exception during execution:",
"timestamp": "2023-02-02T14:36:55.780670+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "f3ee56c5-7e4e-4f41-8b07-73b919a0e0af"
},
{
"id": "609ad5da-cbf9-4dd9-9f24-97532e8e1fdb",
"created": "2023-02-02T14:36:58.403313+00:00",
"updated": "2023-02-02T14:36:58.403313+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.788207+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "07645e3c-99e4-435f-9701-e0aae855743d",
"created": "2023-02-02T14:36:58.403728+00:00",
"updated": "2023-02-02T14:36:58.403728+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 111, in connect_tcp\n stream: anyio.abc.ByteStream = await anyio.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.791059+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "f9d4b9ce-38cc-4674-a0b8-d741d74a6547",
"created": "2023-02-02T14:36:58.404074+00:00",
"updated": "2023-02-02T14:36:58.404074+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 213, in connect_tcp\n async with create_task_group() as tg:",
"timestamp": "2023-02-02T14:36:55.793502+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "3f9e53a0-7355-4533-a370-b295dba4c331",
"created": "2023-02-02T14:36:58.404412+00:00",
"updated": "2023-02-02T14:36:58.404412+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 662, in __aexit__\n raise exceptions[0]",
"timestamp": "2023-02-02T14:36:55.795394+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "74ad2e1e-e8f4-4ba8-9784-053894cb5734",
"created": "2023-02-02T14:36:58.404751+00:00",
"updated": "2023-02-02T14:36:58.404751+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 733, in task_done\n exc = _task.exception()\n ^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.797102+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "f59929d0-7f6d-4c70-bb1e-2f8f183f85db",
"created": "2023-02-02T14:36:58.405008+00:00",
"updated": "2023-02-02T14:36:58.405008+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 164, in try_connect\n stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.798775+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "d178d8ea-dd01-4646-bcd1-d9c18019191f",
"created": "2023-02-02T14:36:58.405248+00:00",
"updated": "2023-02-02T14:36:58.405248+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 1691, in connect_tcp\n await get_running_loop().create_connection(",
"timestamp": "2023-02-02T14:36:55.800499+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "656a9733-d9f4-44c7-a3e1-b0469f09f7e9",
"created": "2023-02-02T14:36:58.405474+00:00",
"updated": "2023-02-02T14:36:58.405474+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 1063, in create_connection\n sock = await self._connect_sock(\n ^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.802115+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "35b42b45-7fd4-4946-a4f1-352f8441ac20",
"created": "2023-02-02T14:36:58.405732+00:00",
"updated": "2023-02-02T14:36:58.405732+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 967, in _connect_sock\n await self.sock_connect(sock, address)",
"timestamp": "2023-02-02T14:36:55.803739+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "4d25a9b0-f4f1-4f9d-a6ac-9aff7e0fb4bb",
"created": "2023-02-02T14:36:58.405941+00:00",
"updated": "2023-02-02T14:36:58.405941+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py\", line 634, in sock_connect\n return await fut\n ^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.805299+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "64eeb0d9-457d-45b2-9e0a-ed0c3632d3d0",
"created": "2023-02-02T14:36:58.406158+00:00",
"updated": "2023-02-02T14:36:58.406158+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "asyncio.exceptions.CancelledError",
"timestamp": "2023-02-02T14:36:55.806900+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "72e1ea46-4b6a-4bda-b8f3-3b357313b419",
"created": "2023-02-02T14:36:58.406384+00:00",
"updated": "2023-02-02T14:36:58.406384+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "\nDuring handling of the above exception, another exception occurred:",
"timestamp": "2023-02-02T14:36:55.808580+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "63c14b7d-3f13-41e5-8042-17e4720fb5ad",
"created": "2023-02-02T14:36:58.406589+00:00",
"updated": "2023-02-02T14:36:58.406589+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.810129+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "2a0f9124-7496-46ea-bca3-f65d6051b13d",
"created": "2023-02-02T14:36:58.406837+00:00",
"updated": "2023-02-02T14:36:58.406837+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 10, in map_exceptions\n yield",
"timestamp": "2023-02-02T14:36:55.811709+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "7fb7edfe-2b6e-4feb-b9f3-3ca3c8565efa",
"created": "2023-02-02T14:36:58.407037+00:00",
"updated": "2023-02-02T14:36:58.407037+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 110, in connect_tcp\n with anyio.fail_after(timeout):",
"timestamp": "2023-02-02T14:36:55.813289+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "ee443f94-cf6e-497a-862e-93f6dd72434b",
"created": "2023-02-02T14:36:58.407246+00:00",
"updated": "2023-02-02T14:36:58.407246+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py\", line 118, in __exit__\n raise TimeoutError",
"timestamp": "2023-02-02T14:36:55.815392+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "f77fb35a-bfeb-4e2f-a0db-f88ac01f8e61",
"created": "2023-02-02T14:36:58.407442+00:00",
"updated": "2023-02-02T14:36:58.407442+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "TimeoutError",
"timestamp": "2023-02-02T14:36:55.817159+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "bed2f64e-6c24-4af5-aa08-f916c9e43402",
"created": "2023-02-02T14:36:58.407743+00:00",
"updated": "2023-02-02T14:36:58.407743+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "\nDuring handling of the above exception, another exception occurred:",
"timestamp": "2023-02-02T14:36:55.818627+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "e2f0c5aa-cd4a-40a5-a041-494346c16f54",
"created": "2023-02-02T14:36:58.408004+00:00",
"updated": "2023-02-02T14:36:58.408004+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.820195+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "bea70530-5753-4ea3-b22e-0b9166fb12dc",
"created": "2023-02-02T14:36:58.408215+00:00",
"updated": "2023-02-02T14:36:58.408215+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 60, in map_httpcore_exceptions\n yield",
"timestamp": "2023-02-02T14:36:55.822050+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "a70c79ab-b624-4eaf-a108-cb77ec281851",
"created": "2023-02-02T14:36:58.408415+00:00",
"updated": "2023-02-02T14:36:58.408415+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 353, in handle_async_request\n resp = await self._pool.handle_async_request(req)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.823631+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "b90cbf7b-42d3-4660-9e76-eb770c795c15",
"created": "2023-02-02T14:36:58.408661+00:00",
"updated": "2023-02-02T14:36:58.408661+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 253, in handle_async_request\n raise exc",
"timestamp": "2023-02-02T14:36:55.825277+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "f1e6243b-b878-4a71-91a4-9ba6d3fd82ac",
"created": "2023-02-02T14:36:58.408911+00:00",
"updated": "2023-02-02T14:36:58.408911+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 237, in handle_async_request\n response = await connection.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.826821+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "4a60d100-38c0-4bb0-8a0e-18ef6c87d4e2",
"created": "2023-02-02T14:36:58.409124+00:00",
"updated": "2023-02-02T14:36:58.409124+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 86, in handle_async_request\n raise exc",
"timestamp": "2023-02-02T14:36:55.828467+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "c56d14fb-2d89-4013-8494-1241bef24253",
"created": "2023-02-02T14:36:58.409334+00:00",
"updated": "2023-02-02T14:36:58.409334+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 63, in handle_async_request\n stream = await self._connect(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.830061+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "4e29a560-e458-4c95-995c-1ab6314abacb",
"created": "2023-02-02T14:36:58.409691+00:00",
"updated": "2023-02-02T14:36:58.409691+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 111, in _connect\n stream = await self._network_backend.connect_tcp(**kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.831689+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "dcb180f3-64f4-4b52-b781-4302b67ae2b5",
"created": "2023-02-02T14:36:58.409973+00:00",
"updated": "2023-02-02T14:36:58.409973+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py\", line 29, in connect_tcp\n return await self._backend.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.833386+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "72e5bbbe-94fb-4ada-b24c-ac5b125117be",
"created": "2023-02-02T14:36:58.410208+00:00",
"updated": "2023-02-02T14:36:58.410208+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 109, in connect_tcp\n with map_exceptions(exc_map):",
"timestamp": "2023-02-02T14:36:55.835017+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "a5a289a6-6e20-4bb9-8734-34742ef0de97",
"created": "2023-02-02T14:36:58.410416+00:00",
"updated": "2023-02-02T14:36:58.410416+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\n self.gen.throw(typ, value, traceback)",
"timestamp": "2023-02-02T14:36:55.836611+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6b1597f7-bfa4-404f-b2a1-4073d149cde1",
"created": "2023-02-02T14:36:58.410684+00:00",
"updated": "2023-02-02T14:36:58.410684+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 14, in map_exceptions\n raise to_exc(exc)",
"timestamp": "2023-02-02T14:36:55.838165+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "d5e3439c-5c0f-4cd8-98ab-7b5d7b1e98e9",
"created": "2023-02-02T14:36:58.410900+00:00",
"updated": "2023-02-02T14:36:58.410900+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "httpcore.ConnectTimeout",
"timestamp": "2023-02-02T14:36:55.839795+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "495c2607-7432-40f5-95ea-ad12ea15d390",
"created": "2023-02-02T14:36:58.411099+00:00",
"updated": "2023-02-02T14:36:58.411099+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "\nThe above exception was the direct cause of the following exception:",
"timestamp": "2023-02-02T14:36:55.841253+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "072de311-04a8-4eaa-a5fe-90ade4b15fb7",
"created": "2023-02-02T14:36:58.411306+00:00",
"updated": "2023-02-02T14:36:58.411306+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.842803+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "d9788c9c-311d-4677-9f3b-8c13d3823934",
"created": "2023-02-02T14:36:58.411507+00:00",
"updated": "2023-02-02T14:36:58.411507+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py\", line 1481, in orchestrate_task_run\n result = await task.fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.844767+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "cb5d0744-7c57-4e7a-b172-720e5373a65a",
"created": "2023-02-02T14:36:58.411734+00:00",
"updated": "2023-02-02T14:36:58.411734+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/src/shared_functions/tasks/files.py\", line 57, in generate_unique_file_name\n flow_run = await client.read_flow_run(flow_run_id)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.846407+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "abda20d7-372c-424b-8f89-a98dccaa5e05",
"created": "2023-02-02T14:36:58.411934+00:00",
"updated": "2023-02-02T14:36:58.411934+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/orion.py\", line 1532, in read_flow_run\n response = await self._client.get(f\"/flow_runs/{flow_run_id}\")\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.848468+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "52e3d965-c3d7-4c16-9286-e6dece99f85d",
"created": "2023-02-02T14:36:58.412131+00:00",
"updated": "2023-02-02T14:36:58.412131+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1757, in get\n return await self.request(\n ^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.850493+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "02ea6800-cc49-4bb1-8dbc-c811dfab10f6",
"created": "2023-02-02T14:36:58.412338+00:00",
"updated": "2023-02-02T14:36:58.412338+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1533, in request\n return await self.send(request, auth=auth, follow_redirects=follow_redirects)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.852257+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "9a7c17d3-2a75-42b3-b57e-97da4e476b23",
"created": "2023-02-02T14:36:58.412694+00:00",
"updated": "2023-02-02T14:36:58.412694+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py\", line 229, in send\n response = await self._send_with_retry(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.854158+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "60171974-9ae6-4d28-9bd4-44b5a0c833df",
"created": "2023-02-02T14:36:58.412937+00:00",
"updated": "2023-02-02T14:36:58.412937+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py\", line 187, in _send_with_retry\n response = await request()\n ^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.855935+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "12377f2b-7a22-4117-9f51-ce5216aa7bc5",
"created": "2023-02-02T14:36:58.413250+00:00",
"updated": "2023-02-02T14:36:58.413250+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1620, in send\n response = await self._send_handling_auth(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.857666+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "0e5fb02c-36ff-43fc-8ec7-2e63d6edc11d",
"created": "2023-02-02T14:36:58.413580+00:00",
"updated": "2023-02-02T14:36:58.413580+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1648, in _send_handling_auth\n response = await self._send_handling_redirects(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.859422+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "1fc37919-3fcf-4272-a8cf-33ad33c301ec",
"created": "2023-02-02T14:36:58.413875+00:00",
"updated": "2023-02-02T14:36:58.413875+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1685, in _send_handling_redirects\n response = await self._send_single_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.861125+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "1a5f76c5-dd8d-48de-a7aa-003be8abe6a3",
"created": "2023-02-02T14:36:58.414083+00:00",
"updated": "2023-02-02T14:36:58.414083+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1722, in _send_single_request\n response = await transport.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.862804+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "9665979c-9272-49f8-8f38-7259ae76512e",
"created": "2023-02-02T14:36:58.414296+00:00",
"updated": "2023-02-02T14:36:58.414296+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 352, in handle_async_request\n with map_httpcore_exceptions():",
"timestamp": "2023-02-02T14:36:55.864488+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "eed70ad4-dbc6-4583-8250-7da336a35c89",
"created": "2023-02-02T14:36:58.414500+00:00",
"updated": "2023-02-02T14:36:58.414500+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\n self.gen.throw(typ, value, traceback)",
"timestamp": "2023-02-02T14:36:55.866098+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "c9c18642-1ef0-4de7-b732-f9ceac951748",
"created": "2023-02-02T14:36:58.414750+00:00",
"updated": "2023-02-02T14:36:58.414750+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 77, in map_httpcore_exceptions\n raise mapped_exc(message) from exc",
"timestamp": "2023-02-02T14:36:55.867717+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "e598cbe0-f78f-43a0-9f0e-625c9fc0925a",
"created": "2023-02-02T14:36:58.414958+00:00",
"updated": "2023-02-02T14:36:58.414958+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "httpx.ConnectTimeout",
"timestamp": "2023-02-02T14:36:55.871416+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "3d15c7f6-505a-4812-8275-54eaf060f22b",
"created": "2023-02-02T14:36:58.415488+00:00",
"updated": "2023-02-02T14:36:58.415488+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.886906+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6cdf2291-8ba9-470b-af0c-30640c52f1fd",
"created": "2023-02-02T14:36:58.415777+00:00",
"updated": "2023-02-02T14:36:58.415777+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 111, in connect_tcp\n stream: anyio.abc.ByteStream = await anyio.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.889283+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "053589f3-8f97-431e-91c7-1e7878db5898",
"created": "2023-02-02T14:36:58.415997+00:00",
"updated": "2023-02-02T14:36:58.415997+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 213, in connect_tcp\n async with create_task_group() as tg:",
"timestamp": "2023-02-02T14:36:55.891296+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "e1905074-551f-4c4f-8adf-562b68bc3960",
"created": "2023-02-02T14:36:58.416221+00:00",
"updated": "2023-02-02T14:36:58.416221+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 662, in __aexit__\n raise exceptions[0]",
"timestamp": "2023-02-02T14:36:55.893148+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "d8dfc7fa-a548-4202-b83d-3868cec1993b",
"created": "2023-02-02T14:36:58.416427+00:00",
"updated": "2023-02-02T14:36:58.416427+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 733, in task_done\n exc = _task.exception()\n ^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.894983+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "638420e7-8a65-4bce-82b7-c65b981b54ba",
"created": "2023-02-02T14:36:58.416691+00:00",
"updated": "2023-02-02T14:36:58.416691+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 164, in try_connect\n stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.896743+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "41c4cb4e-8e7c-40c4-a6df-3a9936d192dd",
"created": "2023-02-02T14:36:58.416898+00:00",
"updated": "2023-02-02T14:36:58.416898+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 1691, in connect_tcp\n await get_running_loop().create_connection(",
"timestamp": "2023-02-02T14:36:55.898460+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "1601d460-c79d-49c4-9975-212473eb51b8",
"created": "2023-02-02T14:36:58.417097+00:00",
"updated": "2023-02-02T14:36:58.417097+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 1063, in create_connection\n sock = await self._connect_sock(\n ^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.900126+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "685ba6cb-3197-4f08-a2bc-84c36fc86e5e",
"created": "2023-02-02T14:36:58.417303+00:00",
"updated": "2023-02-02T14:36:58.417303+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 967, in _connect_sock\n await self.sock_connect(sock, address)",
"timestamp": "2023-02-02T14:36:55.901790+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "1c4249ac-6a46-4635-8046-fb758b39c8c9",
"created": "2023-02-02T14:36:58.417514+00:00",
"updated": "2023-02-02T14:36:58.417514+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py\", line 634, in sock_connect\n return await fut\n ^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.903425+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "29add1c3-788b-44bc-97ac-72085aa98fd9",
"created": "2023-02-02T14:36:58.417740+00:00",
"updated": "2023-02-02T14:36:58.417740+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "asyncio.exceptions.CancelledError",
"timestamp": "2023-02-02T14:36:55.905083+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "30a08a9a-a1fb-4291-9942-c32cf060c430",
"created": "2023-02-02T14:36:58.417949+00:00",
"updated": "2023-02-02T14:36:58.417949+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "\nDuring handling of the above exception, another exception occurred:",
"timestamp": "2023-02-02T14:36:55.906599+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "a63ffd47-55ec-4bed-8829-822e1abc1d4d",
"created": "2023-02-02T14:36:58.418216+00:00",
"updated": "2023-02-02T14:36:58.418216+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.908164+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "daa0b7e2-9d71-41f2-96dd-0f629438baf0",
"created": "2023-02-02T14:36:58.418518+00:00",
"updated": "2023-02-02T14:36:58.418518+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 10, in map_exceptions\n yield",
"timestamp": "2023-02-02T14:36:55.909782+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "2cc898ba-2106-47be-8759-900330d1632e",
"created": "2023-02-02T14:36:58.418864+00:00",
"updated": "2023-02-02T14:36:58.418864+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 110, in connect_tcp\n with anyio.fail_after(timeout):",
"timestamp": "2023-02-02T14:36:55.911485+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "8a4c3b0d-7da2-4983-ba90-4541a9d2c594",
"created": "2023-02-02T14:36:58.419151+00:00",
"updated": "2023-02-02T14:36:58.419151+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py\", line 118, in __exit__\n raise TimeoutError",
"timestamp": "2023-02-02T14:36:55.913141+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "301c246e-1695-498c-a968-e5149d5705ac",
"created": "2023-02-02T14:36:58.419368+00:00",
"updated": "2023-02-02T14:36:58.419368+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "TimeoutError",
"timestamp": "2023-02-02T14:36:55.914776+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "08e5c0c8-bcad-4026-9ea1-e7ff47cff69c",
"created": "2023-02-02T14:36:58.419572+00:00",
"updated": "2023-02-02T14:36:58.419572+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "\nDuring handling of the above exception, another exception occurred:",
"timestamp": "2023-02-02T14:36:55.916261+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6bc2b522-8a2c-42df-8afa-7efa4024460c",
"created": "2023-02-02T14:36:58.419912+00:00",
"updated": "2023-02-02T14:36:58.419912+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.917822+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "8ee9680e-7d44-4caf-8f04-24debbd53afc",
"created": "2023-02-02T14:36:58.420213+00:00",
"updated": "2023-02-02T14:36:58.420213+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 60, in map_httpcore_exceptions\n yield",
"timestamp": "2023-02-02T14:36:55.919700+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "8badf708-269b-4c58-b389-1c59306e8040",
"created": "2023-02-02T14:36:58.420523+00:00",
"updated": "2023-02-02T14:36:58.420523+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 353, in handle_async_request\n resp = await self._pool.handle_async_request(req)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.921297+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "e90ba372-c0a9-40ed-bdc1-7227c07b8939",
"created": "2023-02-02T14:36:58.420862+00:00",
"updated": "2023-02-02T14:36:58.420862+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 253, in handle_async_request\n raise exc",
"timestamp": "2023-02-02T14:36:55.922979+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "947dad02-02ef-4bdc-aef7-3e34d28ba31f",
"created": "2023-02-02T14:36:58.421070+00:00",
"updated": "2023-02-02T14:36:58.421070+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 237, in handle_async_request\n response = await connection.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.924627+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "792df1db-b8cb-4d0e-b3c3-46e7777932d1",
"created": "2023-02-02T14:36:58.421282+00:00",
"updated": "2023-02-02T14:36:58.421282+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 86, in handle_async_request\n raise exc",
"timestamp": "2023-02-02T14:36:55.926306+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "8f481c61-95d1-4335-9df9-1cb7bbe051fb",
"created": "2023-02-02T14:36:58.421480+00:00",
"updated": "2023-02-02T14:36:58.421480+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 63, in handle_async_request\n stream = await self._connect(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.927948+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "328036d5-6258-40c8-9604-e70c8b267e1f",
"created": "2023-02-02T14:36:58.421721+00:00",
"updated": "2023-02-02T14:36:58.421721+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 111, in _connect\n stream = await self._network_backend.connect_tcp(**kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.929599+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "e2f711fa-c70d-43e9-b2d3-798acb265c9c",
"created": "2023-02-02T14:36:58.421931+00:00",
"updated": "2023-02-02T14:36:58.421931+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py\", line 29, in connect_tcp\n return await self._backend.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.931246+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "be8afea8-4f7d-4381-b1d0-16d49251085c",
"created": "2023-02-02T14:36:58.422185+00:00",
"updated": "2023-02-02T14:36:58.422185+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 109, in connect_tcp\n with map_exceptions(exc_map):",
"timestamp": "2023-02-02T14:36:55.933029+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6b286942-400b-4602-8cdd-ab36406b35a3",
"created": "2023-02-02T14:36:58.422461+00:00",
"updated": "2023-02-02T14:36:58.422461+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\n self.gen.throw(typ, value, traceback)",
"timestamp": "2023-02-02T14:36:55.934675+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "d5748ff9-1637-4921-9053-95990ae9bbfe",
"created": "2023-02-02T14:36:58.422803+00:00",
"updated": "2023-02-02T14:36:58.422803+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 14, in map_exceptions\n raise to_exc(exc)",
"timestamp": "2023-02-02T14:36:55.936327+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "4eb488fd-088c-48e3-b206-0f67b4590059",
"created": "2023-02-02T14:36:58.423050+00:00",
"updated": "2023-02-02T14:36:58.423050+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "httpcore.ConnectTimeout",
"timestamp": "2023-02-02T14:36:55.937977+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6d88eca0-4900-45fe-a5fb-4a3d3aa24fea",
"created": "2023-02-02T14:36:58.423258+00:00",
"updated": "2023-02-02T14:36:58.423258+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "\nThe above exception was the direct cause of the following exception:",
"timestamp": "2023-02-02T14:36:55.939500+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "8863456c-dd39-48f0-9b7e-4d4bb9b4ff5a",
"created": "2023-02-02T14:36:58.423459+00:00",
"updated": "2023-02-02T14:36:58.423459+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "Traceback (most recent call last):",
"timestamp": "2023-02-02T14:36:55.941080+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "02d06607-a0bf-437d-b49c-36f3081a3403",
"created": "2023-02-02T14:36:58.423694+00:00",
"updated": "2023-02-02T14:36:58.423694+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py\", line 1481, in orchestrate_task_run\n result = await task.fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.943050+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "a4cb84ea-8c6c-458d-ad13-03ae6300aae8",
"created": "2023-02-02T14:36:58.423941+00:00",
"updated": "2023-02-02T14:36:58.423941+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/src/shared_functions/tasks/files.py\", line 57, in generate_unique_file_name\n flow_run = await client.read_flow_run(flow_run_id)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.944767+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "39aee099-7f8b-4547-a94e-71db8ac37ead",
"created": "2023-02-02T14:36:58.424144+00:00",
"updated": "2023-02-02T14:36:58.424144+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/orion.py\", line 1532, in read_flow_run\n response = await self._client.get(f\"/flow_runs/{flow_run_id}\")\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.946448+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "48b702a3-fc8f-4367-bda5-a229adda32e3",
"created": "2023-02-02T14:36:58.424405+00:00",
"updated": "2023-02-02T14:36:58.424405+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1757, in get\n return await self.request(\n ^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.948139+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "984a0264-e5ee-4f54-85e7-63633576e36e",
"created": "2023-02-02T14:36:58.424608+00:00",
"updated": "2023-02-02T14:36:58.424608+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1533, in request\n return await self.send(request, auth=auth, follow_redirects=follow_redirects)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.949789+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "0954e44c-e6c8-4dae-aae9-ad747dcd5f8e",
"created": "2023-02-02T14:36:58.424854+00:00",
"updated": "2023-02-02T14:36:58.424854+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py\", line 229, in send\n response = await self._send_with_retry(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.951479+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "872af382-419c-4bd6-8cc2-d1d7e1841e68",
"created": "2023-02-02T14:36:58.425053+00:00",
"updated": "2023-02-02T14:36:58.425053+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py\", line 187, in _send_with_retry\n response = await request()\n ^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.953143+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "54a83da4-8dc9-4e18-a819-10cc20cd88cb",
"created": "2023-02-02T14:36:58.425259+00:00",
"updated": "2023-02-02T14:36:58.425259+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1620, in send\n response = await self._send_handling_auth(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.954829+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "1293fc41-95d2-4cee-8408-97f6a3421a0c",
"created": "2023-02-02T14:36:58.425535+00:00",
"updated": "2023-02-02T14:36:58.425535+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1648, in _send_handling_auth\n response = await self._send_handling_redirects(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.956497+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "70f67564-9a9a-407e-9906-220945412b05",
"created": "2023-02-02T14:36:58.425834+00:00",
"updated": "2023-02-02T14:36:58.425834+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1685, in _send_handling_redirects\n response = await self._send_single_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.958136+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "548efeec-1e33-4891-af4b-23ffe3fe98c1",
"created": "2023-02-02T14:36:58.426111+00:00",
"updated": "2023-02-02T14:36:58.426111+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1722, in _send_single_request\n response = await transport.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^",
"timestamp": "2023-02-02T14:36:55.959809+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "80cfaaa5-0383-4da0-a078-b39687959286",
"created": "2023-02-02T14:36:58.426323+00:00",
"updated": "2023-02-02T14:36:58.426323+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 352, in handle_async_request\n with map_httpcore_exceptions():",
"timestamp": "2023-02-02T14:36:55.961483+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "6f6acb6e-beea-4b87-90b9-c40cc87accd3",
"created": "2023-02-02T14:36:58.426553+00:00",
"updated": "2023-02-02T14:36:58.426553+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\n self.gen.throw(typ, value, traceback)",
"timestamp": "2023-02-02T14:36:55.963101+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "34cee411-9dfc-4885-92eb-4d1ccd81ee36",
"created": "2023-02-02T14:36:58.426795+00:00",
"updated": "2023-02-02T14:36:58.426795+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": " File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 77, in map_httpcore_exceptions\n raise mapped_exc(message) from exc",
"timestamp": "2023-02-02T14:36:55.964738+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "4b8a68c3-0551-41fc-95ef-fa8d47a8d0e5",
"created": "2023-02-02T14:36:58.426995+00:00",
"updated": "2023-02-02T14:36:58.426995+00:00",
"name": "prefect.flow_runs",
"level": 20,
"message": "httpx.ConnectTimeout",
"timestamp": "2023-02-02T14:36:55.966402+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
},
{
"id": "4b56cc9e-6838-4ee2-afe9-51abf4be28eb",
"created": "2023-02-02T14:37:04.110847+00:00",
"updated": "2023-02-02T14:37:04.110847+00:00",
"name": "prefect.task_runs",
"level": 40,
"message": "Finished in state Failed('Task run encountered an exception: Traceback (most recent call last):\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 111, in connect_tcp\\n stream: anyio.abc.ByteStream = await anyio.connect_tcp(\\n ^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 213, in connect_tcp\\n async with create_task_group() as tg:\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 662, in __aexit__\\n raise exceptions[0]\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 733, in task_done\\n exc = _task.exception()\\n ^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 164, in try_connect\\n stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)\\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 1691, in connect_tcp\\n await get_running_loop().create_connection(\\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 1063, in create_connection\\n sock = await self._connect_sock(\\n ^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 967, in _connect_sock\\n await self.sock_connect(sock, address)\\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py\", line 634, in sock_connect\\n return await fut\\n ^^^^^^^^^\\nasyncio.exceptions.CancelledError\\n\\nDuring handling of the above exception, another exception occurred:\\n\\nTraceback (most recent call last):\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 10, in map_exceptions\\n yield\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 110, in connect_tcp\\n with anyio.fail_after(timeout):\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py\", line 118, in __exit__\\n raise TimeoutError\\nTimeoutError\\n\\nDuring handling of the above exception, another exception occurred:\\n\\nTraceback (most recent call last):\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 60, in map_httpcore_exceptions\\n yield\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 353, in handle_async_request\\n resp = await self._pool.handle_async_request(req)\\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 253, in handle_async_request\\n raise exc\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 237, in handle_async_request\\n response = await connection.handle_async_request(request)\\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 86, in handle_async_request\\n raise exc\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 63, in handle_async_request\\n stream = await self._connect(request)\\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 111, in _connect\\n stream = await self._network_backend.connect_tcp(**kwargs)\\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py\", line 29, in connect_tcp\\n return await self._backend.connect_tcp(\\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 109, in connect_tcp\\n with map_exceptions(exc_map):\\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\\n self.gen.throw(typ, value, traceback)\\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 14, in map_exceptions\\n raise to_exc(exc)\\nhttpcore.ConnectTimeout\\n\\nThe above exception was the direct cause of the following exception:\\n\\nhttpx.ConnectTimeout\\n')",
"timestamp": "2023-02-02T14:37:03.571947+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": "f3ee56c5-7e4e-4f41-8b07-73b919a0e0af"
},
{
"id": "f2e26f40-d83d-4128-9100-fc09e0878e4a",
"created": "2023-02-02T14:37:04.111207+00:00",
"updated": "2023-02-02T14:37:04.111207+00:00",
"name": "prefect.flow_runs",
"level": 40,
"message": "Encountered exception during execution:\nTraceback (most recent call last):\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 111, in connect_tcp\n stream: anyio.abc.ByteStream = await anyio.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 213, in connect_tcp\n async with create_task_group() as tg:\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 662, in __aexit__\n raise exceptions[0]\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 733, in task_done\n exc = _task.exception()\n ^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py\", line 164, in try_connect\n stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 1691, in connect_tcp\n await get_running_loop().create_connection(\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 1063, in create_connection\n sock = await self._connect_sock(\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py\", line 967, in _connect_sock\n await self.sock_connect(sock, address)\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py\", line 634, in sock_connect\n return await fut\n ^^^^^^^^^\nasyncio.exceptions.CancelledError\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 10, in map_exceptions\n yield\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 110, in connect_tcp\n with anyio.fail_after(timeout):\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py\", line 118, in __exit__\n raise TimeoutError\nTimeoutError\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 60, in map_httpcore_exceptions\n yield\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 353, in handle_async_request\n resp = await self._pool.handle_async_request(req)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 253, in handle_async_request\n raise exc\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 237, in handle_async_request\n response = await connection.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 86, in handle_async_request\n raise exc\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 63, in handle_async_request\n stream = await self._connect(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 111, in _connect\n stream = await self._network_backend.connect_tcp(**kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py\", line 29, in connect_tcp\n return await self._backend.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py\", line 109, in connect_tcp\n with map_exceptions(exc_map):\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\n self.gen.throw(typ, value, traceback)\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py\", line 14, in map_exceptions\n raise to_exc(exc)\nhttpcore.ConnectTimeout\n\nThe above exception was the direct cause of the following exception:\n\nTraceback (most recent call last):\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py\", line 643, in orchestrate_flow_run\n result = await run_sync(flow_call)\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/utilities/asyncutils.py\", line 154, in run_sync_in_interruptible_worker_thread\n async with anyio.create_task_group() as tg:\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 662, in __aexit__\n raise exceptions[0]\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/to_thread.py\", line 31, in run_sync\n return await get_asynclib().run_sync_in_worker_thread(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 937, in run_sync_in_worker_thread\n return await future\n ^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 867, in run\n result = context.run(func, *args)\n ^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/utilities/asyncutils.py\", line 135, in capture_worker_thread_and_result\n result = __fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^\n File \"/tmp/tmpt10v8j0gprefect/load_test.py\", line 36, in main\n unique_file_name = generate_unique_file_name(pendulum.now(), pendulum.now())\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/tasks.py\", line 448, in __call__\n return enter_task_run_engine(\n ^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py\", line 933, in enter_task_run_engine\n return run_async_from_worker_thread(begin_run)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/utilities/asyncutils.py\", line 177, in run_async_from_worker_thread\n return anyio.from_thread.run(call)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/from_thread.py\", line 49, in run\n return asynclib.run_async_from_thread(func, *args)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 970, in run_async_from_thread\n return f.result()\n ^^^^^^^^^^\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/concurrent/futures/_base.py\", line 456, in result\n return self.__get_result()\n ^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/concurrent/futures/_base.py\", line 401, in __get_result\n raise self._exception\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py\", line 1082, in get_task_call_return_value\n return await future._result()\n ^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/futures.py\", line 237, in _result\n return await final_state.result(raise_on_failure=raise_on_failure, fetch=True)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/states.py\", line 89, in _get_state_result\n raise await get_state_exception(state)\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py\", line 1481, in orchestrate_task_run\n result = await task.fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/src/shared_functions/tasks/files.py\", line 57, in generate_unique_file_name\n flow_run = await client.read_flow_run(flow_run_id)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/orion.py\", line 1532, in read_flow_run\n response = await self._client.get(f\"/flow_runs/{flow_run_id}\")\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1757, in get\n return await self.request(\n ^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1533, in request\n return await self.send(request, auth=auth, follow_redirects=follow_redirects)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py\", line 229, in send\n response = await self._send_with_retry(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py\", line 187, in _send_with_retry\n response = await request()\n ^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1620, in send\n response = await self._send_handling_auth(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1648, in _send_handling_auth\n response = await self._send_handling_redirects(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1685, in _send_handling_redirects\n response = await self._send_single_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py\", line 1722, in _send_single_request\n response = await transport.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 352, in handle_async_request\n with map_httpcore_exceptions():\n File \"/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py\", line 155, in __exit__\n self.gen.throw(typ, value, traceback)\n File \"/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py\", line 77, in map_httpcore_exceptions\n raise mapped_exc(message) from exc\nhttpx.ConnectTimeout",
"timestamp": "2023-02-02T14:37:03.584165+00:00",
"flow_run_id": "8a8e26b7-423e-46ff-8618-aae5f359f274",
"task_run_id": null
}
]
Raw
load_test.py
import random
import time
from pathlib import Path
import pendulum
from prefect import flow, get_run_logger
from prefect import task
from prefect.client.orion import get_client
from prefect.context import get_run_context
def locate_root_dir(cwd: Path = None) -> Path:
if not cwd:
cwd = Path.cwd()
candidates = [Path(cwd)]
candidates.extend(Path(cwd).parents)
for path in candidates:
poetry_file = path / "pyproject.toml"
if poetry_file.exists():
return poetry_file.parent
else:
raise RuntimeError(f"Could not find a pyproject.toml file in {cwd} or its parents")
def locate_temp_data_dir() -> Path:
return locate_root_dir() / "temp" / "data"
@task
async def is_running_from_deployment() -> bool:
task_run_context = get_run_context()
flow_run_id = task_run_context.task_run.flow_run_id
async with get_client() as client:
flow_run = await client.read_flow_run(flow_run_id)
return bool(flow_run.deployment_id)
@task
async def generate_temp_data_file_path(project_name: str, file_name: Path) -> Path:
temp_root = Path.cwd() if await is_running_from_deployment.fn() else locate_temp_data_dir()
temp_data_file_path = temp_root / project_name / file_name
get_run_logger().debug(f"Generated temp data file path as: {temp_data_file_path}")
return temp_data_file_path
@task
async def generate_unique_file_name(
date_start: Union[None, pendulum.DateTime], date_end: Union[None, pendulum.DateTime], extra_info: str = None
) -> Path:
task_run_context = get_run_context()
flow_run_id = task_run_context.task_run.flow_run_id
async with prefect.client.orion.get_client() as client:
flow_run = await client.read_flow_run(flow_run_id)
flow_id = flow_run.flow_id
flow = await client.read_flow(flow_id)
flow_name = flow.name
today_nodash = f"{pendulum.now():YYYYMMDD}"
date_fmt = "YYYYMMDDHHmm"
from_ = pendulum.instance(date_start).format(date_fmt) if date_start else ""
to = pendulum.instance(date_end).format(date_fmt) if date_end else ""
file_name = f"{flow_name}_{extra_info}_{today_nodash}_{from_}-{to}_{flow_run_id}"
get_run_logger().info(f"Generated file name template: {file_name}")
return file_name
@task
async def get_project_dir_name() -> str:
task_run_context = get_run_context()
flow_run_id = task_run_context.task_run.flow_run_id
async with prefect.client.orion.get_client() as client:
flow_run = await client.read_flow_run(flow_run_id)
flow_id = flow_run.flow_id
flow = await client.read_flow(flow_id)
flow_name = flow.name
if deployment_id := flow_run.deployment_id:
deployment = await client.read_deployment(deployment_id)
deployment_name = deployment.name
else:
deployment_name = "Testing"
dir_name = f"{flow_name}/{deployment_name}"
return dir_name.lower().replace(" ", "-")
@task
def generate_duration(duration) -> int:
if not duration:
duration = random.randint(10, 60)
get_run_logger().info(duration)
return duration
@task
def simulate_etl(duration: int):
start = time.time()
while time.time() - start < duration:
# generate random numbers to create CPU usage
rand = random.random()
@flow(name="Load test")
def main(duration: int = None):
simulate_etl(generate_duration(duration))
proj_dir_name = get_project_dir_name()
unique_file_name = generate_unique_file_name(pendulum.now(), pendulum.now())
temp_zip_file_path = generate_temp_data_file_path(proj_dir_name, "zip_file_name")
# Create 4 deployments with CronSchedule(cron="*/1 * * * *"), and leave running for a while.
# Errors start after a few minutes
Raw
Logs from Prefect UI.txt
Executing 'generate_unique_file_name-2596364c-0' immediately...
04:34:53 PM
Beginning execution...
04:34:54 PM
generate_unique_file_name-2596364c-0
Encountered exception during execution:
04:36:55 PM
generate_unique_file_name-2596364c-0
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 111, in connect_tcp
stream: anyio.abc.ByteStream = await anyio.connect_tcp(
^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 213, in connect_tcp
async with create_task_group() as tg:
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 662, in __aexit__
raise exceptions[0]
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 733, in task_done
exc = _task.exception()
^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 164, in try_connect
stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 1691, in connect_tcp
await get_running_loop().create_connection(
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 1063, in create_connection
sock = await self._connect_sock(
^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 967, in _connect_sock
await self.sock_connect(sock, address)
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py", line 634, in sock_connect
return await fut
^^^^^^^^^
04:36:55 PM
asyncio.exceptions.CancelledError
04:36:55 PM
During handling of the above exception, another exception occurred:
04:36:55 PM
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 10, in map_exceptions
yield
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 110, in connect_tcp
with anyio.fail_after(timeout):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py", line 118, in __exit__
raise TimeoutError
04:36:55 PM
TimeoutError
04:36:55 PM
During handling of the above exception, another exception occurred:
04:36:55 PM
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 60, in map_httpcore_exceptions
yield
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 353, in handle_async_request
resp = await self._pool.handle_async_request(req)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 253, in handle_async_request
raise exc
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 237, in handle_async_request
response = await connection.handle_async_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 86, in handle_async_request
raise exc
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 63, in handle_async_request
stream = await self._connect(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 111, in _connect
stream = await self._network_backend.connect_tcp(**kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py", line 29, in connect_tcp
return await self._backend.connect_tcp(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 109, in connect_tcp
with map_exceptions(exc_map):
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__
self.gen.throw(typ, value, traceback)
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 14, in map_exceptions
raise to_exc(exc)
04:36:55 PM
httpcore.ConnectTimeout
04:36:55 PM
The above exception was the direct cause of the following exception:
04:36:55 PM
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py", line 1481, in orchestrate_task_run
result = await task.fn(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/src/shared_functions/tasks/files.py", line 57, in generate_unique_file_name
flow_run = await client.read_flow_run(flow_run_id)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/orion.py", line 1532, in read_flow_run
response = await self._client.get(f"/flow_runs/{flow_run_id}")
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1757, in get
return await self.request(
^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1533, in request
return await self.send(request, auth=auth, follow_redirects=follow_redirects)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py", line 229, in send
response = await self._send_with_retry(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py", line 187, in _send_with_retry
response = await request()
^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1620, in send
response = await self._send_handling_auth(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1648, in _send_handling_auth
response = await self._send_handling_redirects(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1685, in _send_handling_redirects
response = await self._send_single_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1722, in _send_single_request
response = await transport.handle_async_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 352, in handle_async_request
with map_httpcore_exceptions():
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__
self.gen.throw(typ, value, traceback)
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 77, in map_httpcore_exceptions
raise mapped_exc(message) from exc
04:36:55 PM
httpx.ConnectTimeout
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 111, in connect_tcp
stream: anyio.abc.ByteStream = await anyio.connect_tcp(
^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 213, in connect_tcp
async with create_task_group() as tg:
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 662, in __aexit__
raise exceptions[0]
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 733, in task_done
exc = _task.exception()
^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 164, in try_connect
stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 1691, in connect_tcp
await get_running_loop().create_connection(
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 1063, in create_connection
sock = await self._connect_sock(
^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 967, in _connect_sock
await self.sock_connect(sock, address)
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py", line 634, in sock_connect
return await fut
^^^^^^^^^
04:36:55 PM
asyncio.exceptions.CancelledError
04:36:55 PM
During handling of the above exception, another exception occurred:
04:36:55 PM
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 10, in map_exceptions
yield
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 110, in connect_tcp
with anyio.fail_after(timeout):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py", line 118, in __exit__
raise TimeoutError
04:36:55 PM
TimeoutError
04:36:55 PM
During handling of the above exception, another exception occurred:
04:36:55 PM
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 60, in map_httpcore_exceptions
yield
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 353, in handle_async_request
resp = await self._pool.handle_async_request(req)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 253, in handle_async_request
raise exc
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 237, in handle_async_request
response = await connection.handle_async_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 86, in handle_async_request
raise exc
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 63, in handle_async_request
stream = await self._connect(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 111, in _connect
stream = await self._network_backend.connect_tcp(**kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py", line 29, in connect_tcp
return await self._backend.connect_tcp(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 109, in connect_tcp
with map_exceptions(exc_map):
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__
self.gen.throw(typ, value, traceback)
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 14, in map_exceptions
raise to_exc(exc)
04:36:55 PM
httpcore.ConnectTimeout
The above exception was the direct cause of the following exception:
04:36:55 PM
Traceback (most recent call last):
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py", line 1481, in orchestrate_task_run
result = await task.fn(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/src/shared_functions/tasks/files.py", line 57, in generate_unique_file_name
flow_run = await client.read_flow_run(flow_run_id)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/orion.py", line 1532, in read_flow_run
response = await self._client.get(f"/flow_runs/{flow_run_id}")
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1757, in get
return await self.request(
^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1533, in request
return await self.send(request, auth=auth, follow_redirects=follow_redirects)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py", line 229, in send
response = await self._send_with_retry(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py", line 187, in _send_with_retry
response = await request()
^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1620, in send
response = await self._send_handling_auth(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1648, in _send_handling_auth
response = await self._send_handling_redirects(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1685, in _send_handling_redirects
response = await self._send_single_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1722, in _send_single_request
response = await transport.handle_async_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 352, in handle_async_request
with map_httpcore_exceptions():
04:36:55 PM
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__
self.gen.throw(typ, value, traceback)
04:36:55 PM
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 77, in map_httpcore_exceptions
raise mapped_exc(message) from exc
04:36:55 PM
httpx.ConnectTimeout
04:36:55 PM
Finished in state Failed('Task run encountered an exception: Traceback (most recent call last):\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 111, in connect_tcp\n stream: anyio.abc.ByteStream = await anyio.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 213, in connect_tcp\n async with create_task_group() as tg:\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 662, in __aexit__\n raise exceptions[0]\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 733, in task_done\n exc = _task.exception()\n ^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 164, in try_connect\n stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 1691, in connect_tcp\n await get_running_loop().create_connection(\n File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 1063, in create_connection\n sock = await self._connect_sock(\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 967, in _connect_sock\n await self.sock_connect(sock, address)\n File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py", line 634, in sock_connect\n return await fut\n ^^^^^^^^^\nasyncio.exceptions.CancelledError\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 10, in map_exceptions\n yield\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 110, in connect_tcp\n with anyio.fail_after(timeout):\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py", line 118, in __exit__\n raise TimeoutError\nTimeoutError\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 60, in map_httpcore_exceptions\n yield\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 353, in handle_async_request\n resp = await self._pool.handle_async_request(req)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 253, in handle_async_request\n raise exc\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 237, in handle_async_request\n response = await connection.handle_async_request(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 86, in handle_async_request\n raise exc\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 63, in handle_async_request\n stream = await self._connect(request)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 111, in _connect\n stream = await self._network_backend.connect_tcp(**kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py", line 29, in connect_tcp\n return await self._backend.connect_tcp(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 109, in connect_tcp\n with map_exceptions(exc_map):\n File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__\n self.gen.throw(typ, value, traceback)\n File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 14, in map_exceptions\n raise to_exc(exc)\nhttpcore.ConnectTimeout\n\nThe above exception was the direct cause of the following exception:\n\nhttpx.ConnectTimeout\n')
Encountered exception during execution:
Traceback (most recent call last):
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 111, in connect_tcp
stream: anyio.abc.ByteStream = await anyio.connect_tcp(
^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 213, in connect_tcp
async with create_task_group() as tg:
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 662, in __aexit__
raise exceptions[0]
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 733, in task_done
exc = _task.exception()
^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_sockets.py", line 164, in try_connect
stream = await asynclib.connect_tcp(remote_host, remote_port, local_address)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 1691, in connect_tcp
await get_running_loop().create_connection(
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 1063, in create_connection
sock = await self._connect_sock(
^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/base_events.py", line 967, in _connect_sock
await self.sock_connect(sock, address)
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/asyncio/selector_events.py", line 634, in sock_connect
return await fut
^^^^^^^^^
asyncio.exceptions.CancelledError
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 10, in map_exceptions
yield
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 110, in connect_tcp
with anyio.fail_after(timeout):
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_core/_tasks.py", line 118, in __exit__
raise TimeoutError
TimeoutError
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 60, in map_httpcore_exceptions
yield
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 353, in handle_async_request
resp = await self._pool.handle_async_request(req)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 253, in handle_async_request
raise exc
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection_pool.py", line 237, in handle_async_request
response = await connection.handle_async_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 86, in handle_async_request
raise exc
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 63, in handle_async_request
stream = await self._connect(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_async/connection.py", line 111, in _connect
stream = await self._network_backend.connect_tcp(**kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/auto.py", line 29, in connect_tcp
return await self._backend.connect_tcp(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/backends/asyncio.py", line 109, in connect_tcp
with map_exceptions(exc_map):
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__
self.gen.throw(typ, value, traceback)
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpcore/_exceptions.py", line 14, in map_exceptions
raise to_exc(exc)
httpcore.ConnectTimeout
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py", line 643, in orchestrate_flow_run
result = await run_sync(flow_call)
^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/utilities/asyncutils.py", line 154, in run_sync_in_interruptible_worker_thread
async with anyio.create_task_group() as tg:
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 662, in __aexit__
raise exceptions[0]
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/to_thread.py", line 31, in run_sync
return await get_asynclib().run_sync_in_worker_thread(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 937, in run_sync_in_worker_thread
return await future
^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 867, in run
result = context.run(func, *args)
^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/utilities/asyncutils.py", line 135, in capture_worker_thread_and_result
result = __fn(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^
File "/tmp/tmpt10v8j0gprefect/load_test.py", line 36, in main
unique_file_name = generate_unique_file_name(pendulum.now(), pendulum.now())
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/tasks.py", line 448, in __call__
return enter_task_run_engine(
^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py", line 933, in enter_task_run_engine
return run_async_from_worker_thread(begin_run)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/utilities/asyncutils.py", line 177, in run_async_from_worker_thread
return anyio.from_thread.run(call)
^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/from_thread.py", line 49, in run
return asynclib.run_async_from_thread(func, *args)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/anyio/_backends/_asyncio.py", line 970, in run_async_from_thread
return f.result()
^^^^^^^^^^
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/concurrent/futures/_base.py", line 456, in result
return self.__get_result()
^^^^^^^^^^^^^^^^^^^
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/concurrent/futures/_base.py", line 401, in __get_result
raise self._exception
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py", line 1082, in get_task_call_return_value
return await future._result()
^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/futures.py", line 237, in _result
return await final_state.result(raise_on_failure=raise_on_failure, fetch=True)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/states.py", line 89, in _get_state_result
raise await get_state_exception(state)
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/engine.py", line 1481, in orchestrate_task_run
result = await task.fn(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/src/shared_functions/tasks/files.py", line 57, in generate_unique_file_name
flow_run = await client.read_flow_run(flow_run_id)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/orion.py", line 1532, in read_flow_run
response = await self._client.get(f"/flow_runs/{flow_run_id}")
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1757, in get
return await self.request(
^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1533, in request
return await self.send(request, auth=auth, follow_redirects=follow_redirects)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py", line 229, in send
response = await self._send_with_retry(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/prefect/client/base.py", line 187, in _send_with_retry
response = await request()
^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1620, in send
response = await self._send_handling_auth(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1648, in _send_handling_auth
response = await self._send_handling_redirects(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1685, in _send_handling_redirects
response = await self._send_single_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_client.py", line 1722, in _send_single_request
response = await transport.handle_async_request(request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 352, in handle_async_request
with map_httpcore_exceptions():
File "/home/prefect/.pyenv/versions/3.11.1/lib/python3.11/contextlib.py", line 155, in __exit__
self.gen.throw(typ, value, traceback)
File "/home/prefect/data_integration/.venv/lib/python3.11/site-packages/httpx/_transports/default.py", line 77, in map_httpcore_exceptions
raise mapped_exc(message) from exc
httpx.ConnectTimeout
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment