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'

@task(checkpoint=False)