Error running dlt pipeline to send loaded table query result to s3!
Traceback (most recent call last):
  File "/usr/local/lib/python3.12/concurrent/futures/thread.py", line 59, in run
    result = self.fn(*self.args, **self.kwargs)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/utils.py", line 235, in _parallel_gen
    return next(gen)  # type: ignore[call-overload]
           ^^^^^^^^^
  File "/app/app/dlt_sources.py", line 124, in query_resource
    yield pa.Table.from_pydict(columnar, schema=schema)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "pyarrow/table.pxi", line 1982, in pyarrow.lib._Tabular.from_pydict
  File "pyarrow/table.pxi", line 6396, in pyarrow.lib._from_pydict
  File "pyarrow/array.pxi", line 405, in pyarrow.lib.asarray
  File "pyarrow/array.pxi", line 365, in pyarrow.lib.array
  File "pyarrow/array.pxi", line 90, in pyarrow.lib._ndarray_to_array
  File "pyarrow/error.pxi", line 92, in pyarrow.lib.check_status
pyarrow.lib.ArrowTypeError: Expected bytes, got a 'dict' object

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

Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 433, in extract
    self._extract_source(
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 1149, in _extract_source
    load_id = extract.extract(
              ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/extract.py", line 404, in extract
    self._extract_single_source(
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/extract.py", line 327, in _extract_single_source
    for pipe_item in pipes:
                     ^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/pipe_iterator.py", line 163, in __next__
    pipe_item = self._futures_pool.resolve_next_future(
                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/concurrency.py", line 182, in resolve_next_future
    return self._resolve_future(future)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/concurrency.py", line 142, in _resolve_future
    raise ResourceExtractionError(pipe.name, future, str(ex), "future") from ex
dlt.extract.exceptions.ResourceExtractionError: In processing pipe testing_version: extraction of resource testing_version in future <Future at 0x7f96ef7e87d0 state=finished raised ArrowTypeError> caused an exception: Expected bytes, got a 'dict' object

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

Traceback (most recent call last):
  File "/app/app/data_pipeline.py", line 1116, in run_pipeline
    pipe_info = s3_pipeline.run(
                ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 222, in _wrap
    step_info = f(self, *args, **kwargs)
                ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 267, in _wrap
    return f(self, *args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 684, in run
    self.extract(
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 222, in _wrap
    step_info = f(self, *args, **kwargs)
                ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 176, in _wrap
    rv = f(self, *args, **kwargs)
         ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 162, in _wrap
    return f(self, *args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 267, in _wrap
    return f(self, *args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/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 1750889838.4088085 with exception:

<class 'dlt.extract.exceptions.ResourceExtractionError'>
In processing pipe testing_version: extraction of resource testing_version in future <Future at 0x7f96ef7e87d0 state=finished raised ArrowTypeError> caused an exception: Expected bytes, got a 'dict' object