class_docstr: Fetch Cloudwatch log events with specific interval and send the log events to the logger.info.
class_docstr_tok: ["Fetch","Cloudwatch","log","events","with","specific","interval","and","send","the","log","events","to","the","logger.info","."]
code: def __init__(
      self,
      *,
      log_group: str,
      log_stream_name: str,
      fetch_interval: timedelta,
      logger: Logger,
      aws_conn_id: str | None = "aws_default",
      region_name: str | None = None,
  ):
      super().__init__()
      self._event = Event()
  
      self.fetch_interval = fetch_interval
  
      self.logger = logger
      self.log_group = log_group
      self.log_stream_name = log_stream_name
  
      self.hook = AwsLogsHook(
          aws_conn_id=aws_conn_id, region_name=region_name
      )
  
file_path: airflow/airflow/providers/amazon/aws/utils/task_log_fetcher.py
imports: from __future__ import annotations
  import time
  from datetime import datetime, timedelta
  from threading import Event, Thread
  from typing import TYPE_CHECKING, Generator
  from botocore.exceptions import ClientError, ConnectionClosedError
  from airflow.providers.amazon.aws.hooks.logs import AwsLogsHook
label_desc: Use image node_id 1 to create a new AwsTaskLogFetcher object from inherited base classes: Thread with example: obj = AwsTaskLogFetcher()