rodrigoassumpcao commented on issue #59272: URL: https://github.com/apache/airflow/issues/59272#issuecomment-3927591647
Hi guys. I'm not an expert with the Airflow source code, but it seems that a commit/flush is missing after a `session.add` in the `_update_import_errors` method of collection.py file. I added a `session.flush()` after line 342 in `airflow/dag_processing/collection.py` file and the `import_error` table starts being populated. Here is the version I used: https://github.com/apache/airflow/blob/3.1.7/airflow-core/src/airflow/dag_processing/collection.py -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
