zachliu commented on issue #49887:
URL: https://github.com/apache/airflow/issues/49887#issuecomment-2864362630
@dramis i was unable to reproduce the issue using this minimal DAG (the
output of `lsof` is small and stable):
```python
"""Test"""
# airflow DAG
from airflow.models.dag import DAG
from airflow.providers.standard.operators.bash import BashOperator
from airflow.timetables.trigger import CronTriggerTimetable
from pendulum import datetime
LOCAL_TZ = "UTC"
with DAG(
dag_id="dummy_daily",
schedule=CronTriggerTimetable("@daily", timezone=LOCAL_TZ),
start_date=datetime(2025, 5, 1, tz=LOCAL_TZ),
max_active_runs=3,
catchup=False,
tags=["flag"],
default_args={"email": "{{ var.value.email }}"},
):
BashOperator(
task_id="print",
bash_command="echo Hello!",
)
```
however i was able to reproduce using this DAG (the output of `lsof` grows
at every `reparse`):
```python
"""Test"""
# airflow DAG
from airflow.sdk import Variable
from airflow.models.dag import DAG
from airflow.providers.standard.operators.bash import BashOperator
from airflow.timetables.trigger import CronTriggerTimetable
from pendulum import datetime
LOCAL_TZ = "UTC"
email = Variable.get(
"email",
default=["[email protected]"],
deserialize_json=False,
)
with DAG(
dag_id="dummy_daily",
schedule=CronTriggerTimetable("@daily", timezone=LOCAL_TZ),
start_date=datetime(2025, 5, 1, tz=LOCAL_TZ),
max_active_runs=3,
catchup=False,
tags=["flag"],
default_args={"email": email},
):
BashOperator(
task_id="print",
bash_command="echo Hello!",
)
```
--
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]
