Thuy Tran
08/10/2022, 4:46 AM00:35:13.071 | DEBUG | Flow run 'logical-lemming' - Resolving inputs to 'update-record'
00:35:14.896 | DEBUG | prefect.client - Connecting to API at <http://127.0.0.1:4200/api/>
00:35:17.563 | DEBUG | prefect.agent - Checking for flow runs...
00:35:22.591 | DEBUG | prefect.agent - Checking for flow runs...
--- Orion logging error ---
The log worker encountered a fatal error.
Traceback (most recent call last):
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/site-packages/prefect/logging/handlers.py", line 82, in _send_logs_loop
anyio.run(self.send_logs)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/site-packages/anyio/_core/_eventloop.py", line 70, in run
return asynclib.run(func, *args, **backend_options)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 292, in run
return native_run(wrapper(), debug=debug)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/asyncio/runners.py", line 47, in run
_cancel_all_tasks(loop)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/asyncio/runners.py", line 56, in _cancel_all_tasks
to_cancel = tasks.all_tasks(loop)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/asyncio/tasks.py", line 53, in all_tasks
tasks = list(_all_tasks)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/_weakrefset.py", line 65, in __iter__
for itemref in self.data:
RuntimeError: Set changed size during iteration
Worker information:
Approximate queue length: 0
Pending log batch length: 0
Pending log batch size: 0
00:35:27.618 | DEBUG | prefect.agent - Checking for flow runs...
00:35:32.655 | DEBUG | prefect.agent - Checking for flow runs...
00:35:37.680 | DEBUG | prefect.agent - Checking for flow runs...
00:35:42.713 | DEBUG | prefect.agent - Checking for flow runs...
00:35:46.427 | DEBUG | prefect.flows - Parameter 'target_collection' for flow 'update-record' is of unserializable type 'Collection' and will not be stored in the backend.
00:35:46.427 | DEBUG | prefect.flows - Parameter 'sys_collection' for flow 'update-record' is of unserializable type 'Collection' and will not be stored in the backend.
00:35:46.427 | DEBUG | prefect.flows - Parameter 'metadata_collection' for flow 'update-record' is of unserializable type 'Collection' and will not be stored in the backend.
00:35:47.751 | DEBUG | prefect.agent - Checking for flow runs...
00:35:48.177 | INFO | Flow run 'logical-lemming' - Created subflow run 'knowing-avocet' for flow 'update-record'
00:35:48.395 | ERROR | Flow run 'knowing-avocet' - Received invalid parameters
Traceback (most recent call last):
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/site-packages/prefect/engine.py", line 433, in create_and_begin_subflow_run
parameters = flow.validate_parameters(parameters)
File "/Applications/anaconda3/envs/datapipeline/lib/python3.9/site-packages/prefect/flows.py", line 275, in validate_parameters
raise validation_err
prefect.exceptions.ParameterTypeError: 1 validation error for UpdateRecord
end_date
str type expected (type=type_error.str)
00:35:48.435 | INFO | Flow run 'logical-lemming' - Created task run 'update_record_in_db-a12634ec-0' for task 'update_record_in_db'
00:35:48.435 | INFO | Flow run 'logical-
Anna Geller
Anna Geller