Seth Just
03/03/2022, 8:15 PMECSRun
with a LocalDaskExecutor
and I'm unable to find any way to debug or diagnose why the task isn't ever executed.Kevin Kho
03/03/2022, 8:17 PMSeth Just
03/03/2022, 8:17 PMKevin Kho
03/03/2022, 8:18 PMSeth Just
03/03/2022, 8:19 PMKevin Kho
03/03/2022, 8:22 PMSeth Just
03/03/2022, 8:23 PMKevin Kho
03/03/2022, 8:24 PMflow.executor = LocalDaskExecutor()
?Seth Just
03/03/2022, 8:32 PMwith Flow(
"encyclopedia-flow",
result=PrefectResult(),
storage=STORAGE,
run_config=RUN_CONFIG,
executor=LocalDaskExecutor(scheduler="processes"),
) as flow:
Kevin Kho
03/03/2022, 9:02 PMSeth Just
03/03/2022, 9:48 PMKevin Kho
03/03/2022, 10:04 PMPREFECT___LOGGING___LEVEL:"DEBUG"
as an environment variableSeth Just
03/03/2022, 10:07 PMKevin Kho
03/04/2022, 4:45 PMSeth Just
03/04/2022, 4:45 PMWaiterError
(from boto3
). In AWSClientWait
the error is handled as raise FAIL(...) from e
AWSClientWait.run()
from within another task)└── 15:47:21 | ERROR | Unexpected error: TypeError("__init__() missing 1 required positional argument: 'last_response'")
Traceback (most recent call last):
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/prefect/engine/runner.py", line 48, in inner
new_state = method(self, state, *args, **kwargs)
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/prefect/engine/flow_runner.py", line 643, in get_flow_run_state
final_states = executor.wait(
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/prefect/executors/dask.py", line 685, in wait
return dask.compute(
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/dask/base.py", line 571, in compute
results = schedule(dsk, keys, **kwargs)
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/dask/multiprocessing.py", line 219, in get
result = get_async(
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/dask/local.py", line 508, in get_async
res, worker_id = loads(res_info)
File "/home/sethjust/miniconda3/envs/seerbio-venv-py38/lib/python3.8/site-packages/botocore/exceptions.py", line 28, in _exception_from_packed_args
return exception_cls(*args, **kwargs)
TypeError: __init__() missing 1 required positional argument: 'last_response'