You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2023/10/29 22:40:03 UTC
(airflow) 11/44: Remove unused set from `SchedulerJobRunner` (#34810)
This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch v2-7-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 979a4e442923f88d862e282d9d4d66d0298be81f
Author: Jed Cunningham <66...@users.noreply.github.com>
AuthorDate: Sun Oct 8 07:07:21 2023 -0600
Remove unused set from `SchedulerJobRunner` (#34810)
(cherry picked from commit d4de5c39bce0a5193ed117ccd8359925999e5bbb)
---
airflow/jobs/scheduler_job_runner.py | 1 -
1 file changed, 1 deletion(-)
diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py
index c92ff805cb..c8494c8731 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -227,7 +227,6 @@ class SchedulerJobRunner(BaseJobRunner[Job], LoggingMixin):
self.processor_agent: DagFileProcessorAgent | None = None
self.dagbag = DagBag(dag_folder=self.subdir, read_dags_from_db=True, load_op_links=False)
- self._paused_dag_without_running_dagruns: set = set()
@provide_session
def heartbeat_callback(self, session: Session = NEW_SESSION) -> None: