Skip to content

Commit

Permalink
Remove unused set from SchedulerJobRunner (#34810)
Browse files Browse the repository at this point in the history
(cherry picked from commit d4de5c3)
  • Loading branch information
jedcunningham authored and ephraimbuddy committed Oct 30, 2023
1 parent 8a83d40 commit aff98bf
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion airflow/jobs/scheduler_job_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,6 @@ def __init__(
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:
Expand Down

0 comments on commit aff98bf

Please sign in to comment.