Anyone ever run into this error before? `Unexpecte...
# prefect-community
j
Anyone ever run into this error before?
Unexpected 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.
1
Full Stacktrace:
Copy code
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'
I’m running a prefect docker agent to execute with “Local Dask Executor”
a
sorry, not enough info to help atm, can you provide more context?
the error looks like pickle issue, can you disable checkpointing for this task?
Copy code
@task(checkpoint=False)
j
It was user error masked by the no-logging bug in the Dask Executor on “Processes” mode.
a
I see, thanks for the update