From 1486952ceebd8b843d93688b7a08a972c91981fd Mon Sep 17 00:00:00 2001 From: kanga333 Date: Tue, 15 Feb 2022 16:14:12 +0900 Subject: [PATCH] Get log events after sleep to get all logs --- airflow/providers/amazon/aws/operators/ecs.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: