ephraimbuddy commented on code in PR #41854:
URL: https://github.com/apache/airflow/pull/41854#discussion_r1735971204
##########
airflow/dag_processing/manager.py:
##########
@@ -527,9 +530,11 @@ def deactivate_stale_dags(
for dag in dags_parsed:
# When the DAG processor runs as part of the scheduler, and the
user changes the DAGs folder,
- # DAGs from the previous DAGs folder will be marked as stale. Note
that this change has no impact
- # on standalone DAG processors.
- dag_not_in_current_dag_folder = os.path.commonpath([dag.fileloc,
dag_directory]) != dag_directory
+ # DAGs from the previous DAGs folder will be marked as stale. We
also need to handle example dags
+ # differently. Note that this change has no impact on standalone
DAG processors.
Review Comment:
Have you tested this with standalone dag processors?
--
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]
