diff --git a/airflow/executors/base_executor.py b/airflow/executors/base_executor.py index 74e58bc0682fd3..e75bc7cb98a110 100644 --- a/airflow/executors/base_executor.py +++ b/airflow/executors/base_executor.py @@ -229,12 +229,6 @@ def heartbeat(self) -> None: self.log.debug("Calling the %s sync method", self.__class__) self.sync() - self.trigger_tasks(open_slots) - - # Calling child class sync method - self.log.debug("Calling the %s sync method", self.__class__) - self.sync() - def _emit_metrics(self, open_slots, num_running_tasks, num_queued_tasks): """ Emit metrics relevant to the Executor.