Josh
07/12/2022, 6:11 PMUnexpected error: TypeError("InvalidSchema.__init__() missing 2 required positional arguments: 'local_schema' and 'remote_schema'")
I’m passing dataframes down to another task and for some reason it’s not able to startup the task at all.Unexpected error: TypeError("InvalidSchema.__init__() missing 2 required positional arguments: 'local_schema' and 'remote_schema'")
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/prefect/engine/runner.py", line 48, in inner
new_state = method(self, state, *args, **kwargs)
File "/usr/local/lib/python3.10/site-packages/prefect/engine/flow_runner.py", line 643, in get_flow_run_state
final_states = executor.wait(
File "/usr/local/lib/python3.10/site-packages/prefect/executors/dask.py", line 685, in wait
return dask.compute(
File "/usr/local/lib/python3.10/site-packages/dask/base.py", line 571, in compute
results = schedule(dsk, keys, **kwargs)
File "/usr/local/lib/python3.10/site-packages/dask/multiprocessing.py", line 219, in get
result = get_async(
File "/usr/local/lib/python3.10/site-packages/dask/local.py", line 508, in get_async
res, worker_id = loads(res_info)
File "/usr/local/lib/python3.10/site-packages/tblib/pickling_support.py", line 26, in unpickle_exception
inst = func(*args)
TypeError: InvalidSchema.__init__() missing 2 required positional arguments: 'local_schema' and 'remote_schema'
Anna Geller
07/12/2022, 6:40 PM@task(checkpoint=False)
Josh
07/13/2022, 7:24 PMAnna Geller
07/13/2022, 9:02 PM