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

During handling of the above exception, another exception occurred:

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

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 106, in query_resource
    yield pa.Table.from_pydict(empty_columnar, schema=schema)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "pyarrow/table.pxi", line 1982, in pyarrow.lib._Tabular.from_pydict
  File "pyarrow/table.pxi", line 6391, in pyarrow.lib._from_pydict
KeyError: "The passed mapping doesn't contain the following field(s) of the schema: timestamp, srcsysid, issorgzcd, orgzcd, glentobjid, blperobjid, busofcobjid, chgcommonobjid, chgobjid, dfltspsiddefobjid, encobjid, fiscperobjid, mstrrevcdobjid, ordhlthprofobjid, parentchgcommonobjid, parentsvcobjid, perfhlthprofobjid, primencobjid, ptlocobjid, rcvownerhpoobjid, refhlthprofobjid, reimbunitobjid, subctrcthpoobjid, subctrctsvcprovobjid, supvhlthprofobjid, svcobjid, svcprovhpoobjid, svcprovobjid, accomchgind, chgconvmne, credtime, initallocdate, lastcngutcdtime, postbusdate, rptpostbusdate, rvsebusdate, rvseind, rvsepostdate, batchshortdesc, batchid, abnstscd, abnstsdate, abnstsmne, authno, autochgruletext, autochgruletypemne, chgcommoncredtime, clinmne, costamt, dseqty, durval, entsrcname, extchgintfcno, extpriceamt, extpurpriceamt, exttotcostamt, itemno, modelno, ndcval, ordno, ovrdsvcname, priceovrdind, primchgintfcno, qty, refno, rxqty, spclprcsmne1, spclprcsmne2, srcapplname, srcsysind, stpdtime, stpdate, strdtime, strdate, svcpriceruletext, svcxpldind, taxonomymne, chgmodfval, rvslind, transtypecd, transtypemne, rcvownerhpoid, subctrcthpoid, svcprovhpoid, chgdxcdval, chgproccdval, revcdval, ptlocid, rvsecommonrsnmne, rvsecommontext, creuserid, lastcnguserid, ordhlthprofspclmne, perfhlthprofspclmne, refhlthprofspclmne, supvhlthprofspclmne, svcprovsvcid, transcommonid, transplantphasemne, unallocind, rvsedind, ndcqty, rxno, uommne, rptsvcdtime, rptsvcdate, transplantcostrptphasemne, dentaltoothnomne, primencmanasgnmne, xpldparentind, clmlinenotetext, feeschedmodfcdval, chgprocmstrclasfobjid, entseqno, entdtime, parentcontchgcommonobjid, physprachpoobjid, allowpostcnclencind, plcofsvcovrdmne, proccddescovrdtext, frgnsysuserid, spclprcsmne3, spclprcsmne4, spclprcsmne5, spclprcsmne6, investigdevexmptno, workrvuval, totrvuval, encplcofsvcmne, point1val, point2val, point3val, point4val, point5val, point6val, plcofsvcmne, latechgind, latechgamt, entsvcid, entsvcidtypemne, chgdx1cdval, chgdx2cdval, chgdx3cdval, chgdx4cdval, chgdx5cdval, chgdx6cdval, chgdx7cdval, chgdx8cdval, chgdx9cdval, chgdx10cdval, chgdx11cdval, chgdx12cdval, blperblptyobjid, blperkey, hfmalatechgind, lastmedncstyrsltobjid, lastmedncstycovexclind, notmedncsryind, medncstypolmemobjid, medncstypyrhlthplanobjid, lastmedncstycheckdtime, gljrnlentobjid, glctrid, ovrdclincd, ovrduomcd, ovrdndcval, chgonlymodfval, svcprovsvcmodfval, svcmodfval, rvuadjfctr, workrvuadjval, totrvuadjval, workrvuorigval, totrvuorigval, sallastcngutcdtime, entsvcidissid, remainqtychgind, intfctransind, resphlthprofobjid, origchgobjid, movedchgind, repricedchgind, spclprcsovrdmne1, spclprcsovrdmne2, spclprcsovrdmne3, spclprcsovrdmne4, spclprcsovrdmne5, spclprcsovrdmne6, sendsysdtime, sendsysutcdtime, sendsysxmitdtime, sendsysxmitutcdtime"

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
    metadata, dlt_source = await get_metadata(dlt_source)
                           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/app/app/pipeline_utils.py", line 663, 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 testing_74125: extraction of resource testing_74125 in future <Future at 0x790594180290 state=finished raised KeyError> caused an exception: "The passed mapping doesn't contain the following field(s) of the schema: timestamp, srcsysid, issorgzcd, orgzcd, glentobjid, blperobjid, busofcobjid, chgcommonobjid, chgobjid, dfltspsiddefobjid, encobjid, fiscperobjid, mstrrevcdobjid, ordhlthprofobjid, parentchgcommonobjid, parentsvcobjid, perfhlthprofobjid, primencobjid, ptlocobjid, rcvownerhpoobjid, refhlthprofobjid, reimbunitobjid, subctrcthpoobjid, subctrctsvcprovobjid, supvhlthprofobjid, svcobjid, svcprovhpoobjid, svcprovobjid, accomchgind, chgconvmne, credtime, initallocdate, lastcngutcdtime, postbusdate, rptpostbusdate, rvsebusdate, rvseind, rvsepostdate, batchshortdesc, batchid, abnstscd, abnstsdate, abnstsmne, authno, autochgruletext, autochgruletypemne, chgcommoncredtime, clinmne, costamt, dseqty, durval, entsrcname, extchgintfcno, extpriceamt, extpurpriceamt, exttotcostamt, itemno, modelno, ndcval, ordno, ovrdsvcname, priceovrdind, primchgintfcno, qty, refno, rxqty, spclprcsmne1, spclprcsmne2, srcapplname, srcsysind, stpdtime, stpdate, strdtime, strdate, svcpriceruletext, svcxpldind, taxonomymne, chgmodfval, rvslind, transtypecd, transtypemne, rcvownerhpoid, subctrcthpoid, svcprovhpoid, chgdxcdval, chgproccdval, revcdval, ptlocid, rvsecommonrsnmne, rvsecommontext, creuserid, lastcnguserid, ordhlthprofspclmne, perfhlthprofspclmne, refhlthprofspclmne, supvhlthprofspclmne, svcprovsvcid, transcommonid, transplantphasemne, unallocind, rvsedind, ndcqty, rxno, uommne, rptsvcdtime, rptsvcdate, transplantcostrptphasemne, dentaltoothnomne, primencmanasgnmne, xpldparentind, clmlinenotetext, feeschedmodfcdval, chgprocmstrclasfobjid, entseqno, entdtime, parentcontchgcommonobjid, physprachpoobjid, allowpostcnclencind, plcofsvcovrdmne, proccddescovrdtext, frgnsysuserid, spclprcsmne3, spclprcsmne4, spclprcsmne5, spclprcsmne6, investigdevexmptno, workrvuval, totrvuval, encplcofsvcmne, point1val, point2val, point3val, point4val, point5val, point6val, plcofsvcmne, latechgind, latechgamt, entsvcid, entsvcidtypemne, chgdx1cdval, chgdx2cdval, chgdx3cdval, chgdx4cdval, chgdx5cdval, chgdx6cdval, chgdx7cdval, chgdx8cdval, chgdx9cdval, chgdx10cdval, chgdx11cdval, chgdx12cdval, blperblptyobjid, blperkey, hfmalatechgind, lastmedncstyrsltobjid, lastmedncstycovexclind, notmedncsryind, medncstypolmemobjid, medncstypyrhlthplanobjid, lastmedncstycheckdtime, gljrnlentobjid, glctrid, ovrdclincd, ovrduomcd, ovrdndcval, chgonlymodfval, svcprovsvcmodfval, svcmodfval, rvuadjfctr, workrvuadjval, totrvuadjval, workrvuorigval, totrvuorigval, sallastcngutcdtime, entsvcidissid, remainqtychgind, intfctransind, resphlthprofobjid, origchgobjid, movedchgind, repricedchgind, spclprcsovrdmne1, spclprcsovrdmne2, spclprcsovrdmne3, spclprcsovrdmne4, spclprcsovrdmne5, spclprcsovrdmne6, sendsysdtime, sendsysutcdtime, sendsysxmitdtime, sendsysxmitutcdtime"