tirkarthi commented on PR #28256:
URL: https://github.com/apache/airflow/pull/28256#issuecomment-1399175298
I am not sure if there is a reliable way to extract
"/home/karthikeyan/airflow/dags/error_dag.zip" from
"/home/karthikeyan/airflow/dags/error_dag.zip/error_dag.py" through zipfile
module for migration of existing errors. If it's just clearing based on zip
file then wouldn't this become a query like below just deleting all zip file
related errors though the zip files haven't changed? It might become like a
query like below that already exists in processor.py
```python
query = session.query(errors.ImportError)
if self._file_paths:
for file_path in self._file_paths:
query =
query.filter(errors.ImportError.filename.startswith(file_path))
query.delete(synchronize_session="fetch")
session.commit()
```
https://github.com/apache/airflow/blob/09b3a29972430e5749d772359692fe4a9d528e48/airflow/dag_processing/processor.py#L563-L566
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
