VladaZakharova opened a new issue, #41976:
URL: https://github.com/apache/airflow/issues/41976
### Description
The following DAG:
```
import datetime
import time
import airflow
from airflow.operators.python import PythonOperator
time.sleep(1000)
with airflow.DAG(
"import_timeout",
start_date=datetime.datetime(2022, 1, 1),
schedule=None) as dag:
def f():
print("Sleeping")
time.sleep(120)
for ind in range(10):
PythonOperator(
dag=dag,
task_id=f"sleep_120_{ind}",
python_callable=f,
)
```
is artificial example of DAG that will be timed out on import in DAG
processor.
In logs of Airflow we can see that there is AirflowTaskTimeout for that DAG:
However, there is nothing exposed in Airflow UI that can give an idea of
this.
The idea is to record import timeouts information in Airflow database and
display it in Airflow UI (similar to DAG import errors).
Althought, it is not clear which model would be better to use, ImportError
or DagWarning?
### Use case/motivation
_No response_
### Related issues
_No response_
### Are you willing to submit a PR?
- [X] Yes I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
--
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]
