Göktuğ Aşcı
11/22/2024, 11:06 PM3.1.3-python12-kubernetes
During handling of the above exception, another exception occurred:
+ Exception Group Traceback (most recent call last):
| File "/usr/local/lib/python3.12/site-packages/prefect/cli/_utilities.py", line 42, in wrapper
| return fn(*args, **kwargs)
| ^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/prefect/cli/_types.py", line 153, in sync_fn
| return asyncio.run(async_fn(*args, **kwargs))
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/asyncio/runners.py", line 194, in run
| return runner.run(main)
| ^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/asyncio/runners.py", line 118, in run
| return self._loop.run_until_complete(task)
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/asyncio/base_events.py", line 687, in run_until_complete
| return future.result()
| ^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/prefect/cli/worker.py", line 167, in start
| await worker.start(
| File "/usr/local/lib/python3.12/site-packages/prefect/workers/base.py", line 549, in start
| async with self as worker:
| ^^^^
| File "/usr/local/lib/python3.12/site-packages/prefect/workers/base.py", line 1240, in __aexit__
| await self.teardown(*exc_info)
| File "/usr/local/lib/python3.12/site-packages/prefect_kubernetes/worker.py", line 626, in teardown
| await super().teardown(*exc_info)
| File "/usr/local/lib/python3.12/site-packages/prefect/workers/base.py", line 659, in teardown
| await self._exit_stack.__aexit__(*exc_info)
| File "/usr/local/lib/python3.12/contextlib.py", line 754, in __aexit__
| raise exc_details[1]
| File "/usr/local/lib/python3.12/contextlib.py", line 737, in __aexit__
| cb_suppress = await cb(*exc_details)
| ^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py", line 763, in __aexit__
| raise BaseExceptionGroup(
| ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
+-+---------------- 1 ----------------
| Exception Group Traceback (most recent call last):
| File "/usr/local/lib/python3.12/site-packages/prefect/workers/base.py", line 553, in start
| async with anyio.create_task_group() as loops_task_group:
| ^^^^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py", line 763, in __aexit__
| raise BaseExceptionGroup(
| ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
+-+---------------- 1 ----------------
| Traceback (most recent call last):
| File "/usr/local/lib/python3.12/site-packages/prefect/utilities/services.py", line 63, in critical_service_loop
| await workload()
| File "/usr/local/lib/python3.12/site-packages/prefect/workers/base.py", line 693, in get_and_submit_flow_runs
| runs_response = await self._get_scheduled_flow_runs()
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/prefect/workers/base.py", line 848, in _get_scheduled_flow_runs
| await self._client.get_scheduled_flow_runs_for_work_pool(
| File "/usr/local/lib/python3.12/site-packages/prefect/client/orchestration.py", line 2899, in get_scheduled_flow_runs_for_work_pool
| return pydantic.TypeAdapter(List[WorkerFlowRunResponse]).validate_python(
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/pydantic/type_adapter.py", line 135, in wrapped
| return func(self, *args, **kwargs)
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^
| File "/usr/local/lib/python3.12/site-packages/pydantic/type_adapter.py", line 366, in validate_python
| return self.validator.validate_python(object, strict=strict, from_attributes=from_attributes, context=context)
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
| pydantic_core._pydantic_core.ValidationError: 1 validation error for list[WorkerFlowRunResponse]
| 0.flow_run.labels
| Input should be a valid dictionary [type=dict_type, input_value=None, input_type=NoneType]
| For further information visit <https://errors.pydantic.dev/2.9/v/dict_type>
+------------------------------------
An exception occurred.
22:58:22.083 | WARNING | EventsWorker - Still processing items: 2 items remaining.
Nate
11/22/2024, 11:10 PMGöktuğ Aşcı
11/22/2024, 11:25 PM