class_docstr: Asynchronously poll the boto3 API and wait for the Batch job to be in the `SUCCEEDED` state.
  
  :param job_id:  A unique identifier for the cluster.
  :param max_retries: The maximum number of attempts to be made.
  :param aws_conn_id: The Airflow connection used for AWS credentials.
  :param region_name: region name to use in AWS Hook
  :param poll_interval: The amount of time in seconds to wait between attempts.
docstr: Serialize BatchOperatorTrigger arguments and classpath.
docstr_tok: ["Serialize","BatchOperatorTrigger","arguments","and","classpath","."]
code: def serialize(self) -> tuple[str, dict[str, Any]]:
      """Serialize BatchOperatorTrigger arguments and classpath."""
      return (
          "airflow.providers.amazon.aws.triggers.batch.BatchOperatorTrigger",
          {
              "job_id": self.job_id,
              "max_retries": self.max_retries,
              "aws_conn_id": self.aws_conn_id,
              "region_name": self.region_name,
              "poll_interval": self.poll_interval,
          },
      )
  
imports: from __future__ import annotations
  import asyncio
  import itertools
  from functools import cached_property
  from typing import TYPE_CHECKING, Any
  from botocore.exceptions import WaiterError
  from deprecated import deprecated
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.providers.amazon.aws.hooks.batch_client import BatchClientHook
  from airflow.providers.amazon.aws.triggers.base import AwsBaseWaiterTrigger
  from airflow.triggers.base import BaseTrigger, TriggerEvent
label_desc: Use image node_id 2 for calling the BatchOperatorTrigger obj's underlying member method code with example usage: obj.serialize() and returns: str,  dict