Error running dlt pipeline to send loaded table query result to s3!
Traceback (most recent call last):
  File "pyarrow/table.pxi", line 6405, in pyarrow.lib._from_pydict
KeyError: 'CHARGE_ITEM_ID'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "pyarrow/table.pxi", line 6408, in pyarrow.lib._from_pydict
KeyError: b'CHARGE_ITEM_ID'

During handling of the above exception, another exception occurred:

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 134, 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 6412, in pyarrow.lib._from_pydict
KeyError: "The passed mapping doesn't contain the following field(s) of the schema: CHARGE_ITEM_ID"

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

Traceback (most recent call last):
  File "/app/app/data_pipeline.py", line 2567, in target_notification
    metadata, dlt_source = await get_metadata(dlt_source)
                           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/app/app/pipeline_utils.py", line 777, 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 duplicatechargenotification: extraction of resource duplicatechargenotification in future <Future at 0x7d62c3094110 state=finished raised KeyError> caused an exception: "The passed mapping doesn't contain the following field(s) of the schema: CHARGE_ITEM_ID"