Error running dlt pipeline to send loaded table query result to s3!
Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/worker.py", line 244, in w_normalize_files
    partial_updates = normalizer(extracted_items_file, root_table_name)
                      ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/items_normalizers.py", line 345, in __call__
    base_schema_update = self._fix_schema_precisions(root_table_name, arrow_schema)
                         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/items_normalizers.py", line 321, in _fix_schema_precisions
    data_type = pyarrow.get_column_type_from_py_arrow(arrow_schema.field(key).type)
                                                      ^^^^^^^^^^^^^^^^^^^^^^^
  File "pyarrow/types.pxi", line 3270, in pyarrow.lib.Schema.field
KeyError: 'Column posted_dt_tm does not exist in schema'

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 505, in normalize
    runner.run_pool(normalize_step.config, normalize_step)
  File "/usr/local/lib/python3.12/site-packages/dlt/common/runners/pool_runner.py", line 89, in run_pool
    while _run_func():
          ^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/common/runners/pool_runner.py", line 82, in _run_func
    run_metrics = run_f.run(cast(TExecutor, pool))
                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/normalize.py", line 299, in run
    self.spool_schema_files(load_id, schema, schema_files)
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/normalize.py", line 241, in spool_schema_files
    self.spool_files(
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/normalize.py", line 175, in spool_files
    schema_updates, writer_metrics = map_f(schema, load_id, files)
                                     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/normalize.py", line 122, in map_parallel
    result: TWorkerRV = pending.result()
                        ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/concurrent/futures/_base.py", line 449, in result
    return self.__get_result()
           ^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/concurrent/futures/_base.py", line 401, in __get_result
    raise self._exception
  File "/usr/local/lib/python3.12/site-packages/dlt/common/runners/pool_runner.py", line 32, in submit
    result = fn(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/normalize/worker.py", line 250, in w_normalize_files
    raise NormalizeJobFailed(load_id, job_id, str(exc), writer_metrics) from exc
dlt.normalize.exceptions.NormalizeJobFailed: Job for oracle.33d8acf261.parquet failed terminally in load 1752526490.0147936 with message 'Column posted_dt_tm does not exist in schema'.

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

Traceback (most recent call last):
  File "/app/app/data_pipeline.py", line 1122, 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 694, in run
    self.normalize(loader_file_format=loader_file_format)
  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 267, in _wrap
    return f(self, *args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/pipeline/pipeline.py", line 509, in normalize
    raise PipelineStepFailed(
dlt.pipeline.exceptions.PipelineStepFailed: Pipeline execution failed at stage normalize when processing package 1752526490.0147936 with exception:

<class 'dlt.normalize.exceptions.NormalizeJobFailed'>
Job for oracle.33d8acf261.parquet failed terminally in load 1752526490.0147936 with message 'Column posted_dt_tm does not exist in schema'.