Thomas Agung Santoso
06/28/2023, 9:46 PMThomas Agung Santoso
06/28/2023, 9:51 PMTraceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/_internal/concurrency/calls.py", line 316, in _run_sync
result = self.fn(*self.args, **self.kwargs)
File "/usr/local/lib/python3.8/queue.py", line 178, in get
raise Empty
_queue.Empty
21:19:51.487 | DEBUG | GlobalEventLoopThread | prefect._internal.concurrency - <AsyncCancelScope, name='get_task_call_return_value' RUNNING, runtime=0.00> entered
21:20:26.934 | DEBUG | GlobalEventLoopThread | prefect._internal.concurrency - Service <prefect.logging.handlers.APILogWorker object at 0x7fa4053d2a90> processing batch of size 401
21:20:26.959 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - Running call get(timeout=1.9999786205589771) in thread 'APILogWorkerThread'
21:20:26.959 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - <WatcherThreadCancelScope, name='get' RUNNING, runtime=0.00> entered
21:20:26.976 | DEBUG | GlobalEventLoopThread | prefect._internal.concurrency - Service <prefect.logging.handlers.APILogWorker object at 0x7fa4053d2a90> enqueing item {'name': 'prefect.flow_runs', 'level': 20, 'message': "Created task run 'load_oracle-0' for task 'load_oracle'", 'timestamp': '2023-06-28T21:20:26.976475+00:00', 'flow_run_id': '8b0da7c4-e157-4e41-a2bd-b87fbb6f96de', 'task_run_id': None, '__payload_size__': 237}
21:20:26.976 | INFO | Flow run 'skilled-galago' - Created task run 'load_oracle-0' for task 'load_oracle'
21:20:26.977 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - <WatcherThreadCancelScope, name='get' COMPLETED, runtime=0.02> exited
21:20:26.978 | DEBUG | GlobalEventLoopThread | prefect._internal.concurrency - Service <prefect.logging.handlers.APILogWorker object at 0x7fa4053d2a90> enqueing item {'name': 'prefect.flow_runs', 'level': 20, 'message': "Executing 'load_oracle-0' immediately...", 'timestamp': '2023-06-28T21:20:26.977770+00:00', 'flow_run_id': '8b0da7c4-e157-4e41-a2bd-b87fbb6f96de', 'task_run_id': None, '__payload_size__': 222}
21:20:26.977 | INFO | Flow run 'skilled-galago' - Executing 'load_oracle-0' immediately...
21:20:26.978 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - Finished call get(timeout=1.9999786205589771)
21:20:26.980 | DEBUG | GlobalEventLoopThread | prefect._internal.concurrency - Service <prefect.logging.handlers.APILogWorker object at 0x7fa4053d2a90> added item {'name': 'prefect.flow_runs', 'level': 20, 'message': "Created task run 'load_oracle-0' for task 'load_oracle'", 'timestamp': '2023-06-28T21:20:26.976475+00:00', 'flow_run_id': '8b0da7c4-e157-4e41-a2bd-b87fbb6f96de', 'task_run_id': None} to batch (size 237/3000000)
21:20:26.980 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - Running call get(timeout=1.9786812588572502) in thread 'APILogWorkerThread'
21:20:26.981 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - <WatcherThreadCancelScope, name='get' RUNNING, runtime=0.00> entered
21:20:26.981 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - <WatcherThreadCancelScope, name='get' COMPLETED, runtime=0.00> exited
21:20:26.981 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - Finished call get(timeout=1.9786812588572502)
21:20:26.981 | DEBUG | GlobalEventLoopThread | prefect._internal.concurrency - Service <prefect.logging.handlers.APILogWorker object at 0x7fa4053d2a90> added item {'name': 'prefect.flow_runs', 'level': 20, 'message': "Executing 'load_oracle-0' immediately...", 'timestamp': '2023-06-28T21:20:26.977770+00:00', 'flow_run_id': '8b0da7c4-e157-4e41-a2bd-b87fbb6f96de', 'task_run_id': None} to batch (size 459/3000000)
21:20:26.981 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - Running call get(timeout=1.9773342795670033) in thread 'APILogWorkerThread'
21:20:26.981 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - <WatcherThreadCancelScope, name='get' RUNNING, runtime=0.00> entered
21:20:28.964 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - <WatcherThreadCancelScope, name='get' COMPLETED, runtime=1.98> exited
21:20:28.965 | DEBUG | APILogWorkerThread | prefect._internal.concurrency - Encountered exception in call get(timeout=1.9773342795670033)
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/_internal/concurrency/calls.py", line 316, in _run_sync
result = self.fn(*self.args, **self.kwargs)
File "/usr/local/lib/python3.8/queue.py", line 178, in get
raise Empty
_queue.Empty
Thomas Agung Santoso
06/28/2023, 10:17 PMNate
06/29/2023, 4:22 PMThomas Agung Santoso
06/29/2023, 4:51 PMNate
06/29/2023, 4:53 PMThomas Agung Santoso
06/29/2023, 5:05 PMNate
06/29/2023, 5:08 PM