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 _get_log_events(
      self, skip_token: AwsLogsHook.ContinuationToken | None = None
  ) -> Generator:
      if skip_token is None:
          skip_token = AwsLogsHook.ContinuationToken()
      try:
          yield from self.hook.get_log_events(
              self.log_group,
              self.log_stream_name,
              continuation_token=skip_token,
          )
      except ClientError as error:
          if (
              error.response["Error"]["Code"]
              != "ResourceNotFoundException"
          ):
              self.logger.warning(
                  "Error on retrieving Cloudwatch log events", error
              )
          else:
              self.logger.info(
                  "Cannot find log stream yet, it can take a couple of seconds to show up. "
                  "If this error persists, check that the log group and stream are correct: "
                  "group: %s\tstream: %s",
                  self.log_group,
                  self.log_stream_name,
              )
          yield from ()
      except ConnectionClosedError as error:
          self.logger.warning(
              "ConnectionClosedError on retrieving Cloudwatch log events",
              error,
          )
          yield from ()
  
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 3 for calling the AwsTaskLogFetcher obj's underlying member method code with example usage: obj._get_log_events(skip_token) without return types