Exception in run_pipeline: PipelineExecutionError
Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/datafabric/datafabric.py", line 985, in _persist_to_datafabric
ValueError: Merge key(s) ['["email"]'] do not exist in target table. Available columns: ['activated', 'client_id', 'client_secret', 'created_at', 'created_by', 'email', 'email_opt_in_ind', 'first_name', 'id', 'last_name', 'mobile_phone', 'provider_account_id', 'role', 'sms_opt_in_ind', 'updated_by']

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 2061, 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 1022, in _persist_to_datafabric
Exception: Error persisting with DuckDB: Merge key(s) ['["email"]'] do not exist in target table. Available columns: ['activated', 'client_id', 'client_secret', 'created_at', 'created_by', 'email', 'email_opt_in_ind', 'first_name', 'id', 'last_name', 'mobile_phone', 'provider_account_id', 'role', 'sms_opt_in_ind', 'updated_by']

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 3651, 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 2068, in _query_to_ipc_bytes
Exception: Error persisting with DuckDB: Merge key(s) ['["email"]'] do not exist in target table. Available columns: ['activated', 'client_id', 'client_secret', 'created_at', 'created_by', 'email', 'email_opt_in_ind', 'first_name', 'id', 'last_name', 'mobile_phone', 'provider_account_id', 'role', 'sms_opt_in_ind', 'updated_by']

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 3656, in query_as_stream
Exception: Error persisting with DuckDB: Merge key(s) ['["email"]'] do not exist in target table. Available columns: ['activated', 'client_id', 'client_secret', 'created_at', 'created_by', 'email', 'email_opt_in_ind', 'first_name', 'id', 'last_name', 'mobile_phone', 'provider_account_id', 'role', 'sms_opt_in_ind', 'updated_by']

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/worker/shared/logging/ps_logging.py", line 58, in wrapper
    result = func(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^^^
  File "/worker/shared/task_handlers/run_pipeline/pipeline.py", line 838, in run_pipeline
    raise PipelineExecutionError("Error executing datafabric query")
shared.task_handlers.run_pipeline.pipeline.PipelineExecutionError: Error executing datafabric query