Error running dlt pipeline to send loaded table query result to s3!
Traceback (most recent call last):
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/pipe_iterator.py", line 274, in _get_source_item
    pipe_item = next(gen)
StopIteration

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/pipe_iterator.py", line 274, in _get_source_item
    pipe_item = next(gen)
  File "/app/app/dlt_sources.py", line 958, in _enrich_from_parquet
    temp_table = create_temp_table_from_pyarrow(
  File "/app/app/dlt_sources.py", line 905, in create_temp_table_from_pyarrow
    raise ValueError(f"Unsupported database type: {database}")
ValueError: Unsupported database type: datafabric

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

Traceback (most recent call last):
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 433, in extract
    self._extract_source(
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 1149, in _extract_source
    load_id = extract.extract(
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/extract.py", line 404, in extract
    self._extract_single_source(
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/extract.py", line 327, in _extract_single_source
    for pipe_item in pipes:
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/pipe_iterator.py", line 158, in __next__
    pipe_item = self._get_source_item()
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/pipe_iterator.py", line 301, in _get_source_item
    return self._get_source_item()
  File "/usr/local/lib/python3.10/site-packages/dlt/extract/pipe_iterator.py", line 305, in _get_source_item
    raise ResourceExtractionError(pipe.name, gen, str(ex), "generator") from ex
dlt.extract.exceptions.ResourceExtractionError: In processing pipe testsourcefield717: extraction of resource testsourcefield717 in generator _enrich_from_parquet caused an exception: Unsupported database type: datafabric

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

Traceback (most recent call last):
  File "/app/app/data_pipeline.py", line 1016, in run_pipeline
    pipe_info = s3_pipeline.run(
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 222, in _wrap
    step_info = f(self, *args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 267, in _wrap
    return f(self, *args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 684, in run
    self.extract(
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 222, in _wrap
    step_info = f(self, *args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 176, in _wrap
    rv = f(self, *args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 162, in _wrap
    return f(self, *args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 267, in _wrap
    return f(self, *args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/dlt/pipeline/pipeline.py", line 453, in extract
    raise PipelineStepFailed(
dlt.pipeline.exceptions.PipelineStepFailed: Pipeline execution failed at stage extract when processing package 1746443351.9416006 with exception:

<class 'dlt.extract.exceptions.ResourceExtractionError'>
In processing pipe testsourcefield717: extraction of resource testsourcefield717 in generator _enrich_from_parquet caused an exception: Unsupported database type: datafabric