diff --git a/airflow/providers/amazon/aws/operators/ecs.py b/airflow/providers/amazon/aws/operators/ecs.py index 9dfdb4406fa37..f982084b64b39 100644 --- a/airflow/providers/amazon/aws/operators/ecs.py +++ b/airflow/providers/amazon/aws/operators/ecs.py @@ -115,11 +115,11 @@ def __init__( def run(self) -> None: logs_to_skip = 0 while not self.is_stopped(): + time.sleep(self.fetch_interval.total_seconds()) log_events = self._get_log_events(logs_to_skip) for log_event in log_events: self.logger.info(self._event_to_str(log_event)) logs_to_skip += 1 - time.sleep(self.fetch_interval.total_seconds()) def _get_log_events(self, skip: int = 0) -> Generator: try: