This message was deleted.

I’m tuned to answer questions specifically about Airbyte, and the log snippet you shared is about a custom Airflow

PythonOperator

task (

file_processing_workflow

) that’s doing Excel-to-CSV conversion and writing to your own database, without any mention of an Airbyte connection, operator, or sync. Because the provided Airbyte documentation and forum excerpts only cover: - Using the Airflow Airbyte Operator to trigger Airbyte syncs and how Airflow logs look when those jobs fail or poll Airbyte’s API [[Airbyte operator](https://docs.airbyte.com/platform/operator-guides/using-the-airflow-airbyte-operator#thats-it); [Airflow forum logs](https://discuss.airbyte.io/t/1490)] - General orchestration with Dagster and Airbyte [[Dagster tutorial](https://airbyte.com/tutorials/orchestrate-data-ingestion-and-transformation-pipelines#step-8)] - Connector changelogs (Confluence, MixMax, Incident.io) [[Confluence changelog](https://docs.airbyte.com/integrations/sources/confluence#changelog); [MixMax changelog](https://docs.airbyte.com/integrations/sources/mixmax#changelog)] there’s no information in these sources that explains or debugs: -

Error fetching last ExecutionLogID: column "DagID" does not exist

-

current transaction is aborted, commands ignored until end of transaction block

- or any part of your custom Excel/SFTP/database logic. If your underlying goal is to orchestrate this file processing together with Airbyte (for example, run an Airbyte sync after these CSVs are created, or replace parts of this logic with Airbyte), I can help you: - show how to add an AirbyteOperator task into this DAG that triggers an Airbyte connection sync, and - point you to how Airflow logs look when calling Airbyte’s API, similar to what’s shown in the Airflow + Airbyte examples and forum thread [[Airflow + Airbyte tutorial](https://airbyte.com/tutorials/how-to-use-airflow-and-airbyte-together); [Airflow operator docs](https://docs.airbyte.com/platform/operator-guides/using-the-airflow-airbyte-operator#thats-it); [Airflow summit thread](https://discuss.airbyte.io/t/1490)]. If you share how Airbyte is involved (e.g., connection ID, where in the DAG you call Airbyte, or any Airbyte-related logs), I can give a more concrete, Airbyte-focused answer.