[GitHub] [airflow] vincbeck commented on a diff in pull request #28476: Migrate DagFileProcessorManager._deactivate_stale_dags to Internal API

vincbeck commented on code in PR #28476: URL: https://github.com/apache/airflow/pull/28476#discussion_r1055787153 ## airflow/api_internal/endpoints/rpc_api_endpoint.py: ## @@ -68,7 +70,10 @@ def internal_airflow_api( log.debug("Calling method %.", {method_name}) try:

[GitHub] [airflow] vincbeck commented on a diff in pull request #28476: Migrate DagFileProcessorManager._deactivate_stale_dags to Internal API

vincbeck commented on code in PR #28476: URL: https://github.com/apache/airflow/pull/28476#discussion_r1053429692 ## airflow/api_internal/endpoints/rpc_api_endpoint.py: ## @@ -68,7 +70,10 @@ def internal_airflow_api( log.debug("Calling method %.", {method_name}) try:

[GitHub] [airflow] vincbeck commented on a diff in pull request #28476: Migrate DagFileProcessorManager._deactivate_stale_dags to Internal API

vincbeck commented on code in PR #28476: URL: https://github.com/apache/airflow/pull/28476#discussion_r1053424381 ## airflow/dag_processing/manager.py: ## @@ -485,51 +486,69 @@ def start(self): return self._run_parsing_loop() @provide_session -def _deactivate