Error executing datafabric query
Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 2056, in _query_to_ipc_bytes
  File "/usr/local/lib/python3.12/site-packages/datafabric/df_logging.py", line 405, in wrapper
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 1597, in _execute_query_to_table
  File "/usr/local/lib/python3.12/site-packages/datafabric/df_logging.py", line 405, in wrapper
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 2360, in _execute_external_query_to_arrow
  File "/usr/local/lib/python3.12/site-packages/adbc_driver_manager/dbapi.py", line 730, in execute
    handle, self._rowcount = _blocking_call(
                             ^^^^^^^^^^^^^^^
  File "adbc_driver_manager/_lib.pyx", line 1606, in adbc_driver_manager._lib._blocking_call_impl
  File "adbc_driver_manager/_lib.pyx", line 1599, in adbc_driver_manager._lib._blocking_call_impl
  File "adbc_driver_manager/_lib.pyx", line 1241, in adbc_driver_manager._lib.AdbcStatement.execute_query
  File "adbc_driver_manager/_lib.pyx", line 260, in adbc_driver_manager._lib.check_error
adbc_driver_manager.ProgrammingError: NOT_FOUND: Failed to prepare query: ERROR:  relation "public.datasourcexx" does not exist
LINE 1: select count(*) from public.datasourcexx
                             ^

Query was:select count(*) from public.datasourcexx. SQLSTATE: 42P01

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 3663, in query_as_stream
  File "/usr/local/lib/python3.12/site-packages/datafabric/df_logging.py", line 405, in wrapper
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 2089, in _query_to_ipc_bytes
Exception: NOT_FOUND: Failed to prepare query: ERROR:  relation "public.datasourcexx" does not exist
LINE 1: select count(*) from public.datasourcexx
                             ^

Query was:select count(*) from public.datasourcexx. SQLSTATE: 42P01

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/worker/shared/task_handlers/run_pipeline/pipeline.py", line 820, in run_pipeline
    reader = df.query_as_stream(
             ^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/datafabric/df_logging.py", line 405, in wrapper
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 3668, in query_as_stream
Exception: NOT_FOUND: Failed to prepare query: ERROR:  relation "public.datasourcexx" does not exist
LINE 1: select count(*) from public.datasourcexx
                             ^

Query was:select count(*) from public.datasourcexx. SQLSTATE: 42P01