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 "/worker/shared/task_handlers/run_pipeline/dlt_sources.py", line 226, in query_resource
    yield pa.Table.from_pydict(columnar, schema=schema)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "pyarrow/table.pxi", line 1985, in pyarrow.lib._Tabular.from_pydict
  File "pyarrow/table.pxi", line 6418, 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 91, in pyarrow.lib._ndarray_to_array
  File "pyarrow/error.pxi", line 92, in pyarrow.lib.check_status
pyarrow.lib.ArrowTypeError: Expected bytes, got a 'decimal.Decimal' object

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 2291, in run_pipeline
    metadata, dlt_source = get_metadata(dlt_source)
                           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/worker/shared/logging/ps_logging.py", line 58, in wrapper
    result = func(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^^^
  File "/worker/shared/pipelines/pipeline_utils.py", line 1029, in get_metadata
    table = next(iter(obj))
            ^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/common/utils.py", line 146, in flatten_list_or_items
    for items in _iter:
                 ^^^^^
dlt.extract.exceptions.ResourceExtractionError: In processing pipe test: extraction of resource test in future <Future at 0x771b5b38d970 state=finished raised ArrowTypeError> caused an exception: Expected bytes, got a 'decimal.Decimal' object