class_docstr: Execute an AppFlow run as is.
  
  .. seealso::
      For more information on how to use this operator, take a look at the guide:
      :ref:`howto/operator:AppflowRunOperator`
  
  :param source: Obsolete, unnecessary for this operator
  :param flow_name: The flow name
  :param poll_interval: how often in seconds to check the query status
  :param aws_conn_id: aws connection to use
  :param region: aws region to use
  :param wait_for_completion: whether to wait for the run to end to return
code: def __init__(
      self,
      flow_name: str,
      source: str | None = None,
      poll_interval: int = 20,
      wait_for_completion: bool = True,
      **kwargs,
  ) -> None:
      if source is not None:
          warnings.warn(
              "The `source` parameter is unused when simply running a flow, please remove it.",
              AirflowProviderDeprecationWarning,
              stacklevel=2,
          )
      super().__init__(
          flow_name=flow_name,
          flow_update=False,
          source_field=None,
          filter_date=None,
          poll_interval=poll_interval,
          wait_for_completion=wait_for_completion,
          **kwargs,
      )
  
imports: from __future__ import annotations
  import time
  import warnings
  from datetime import datetime, timedelta
  from typing import TYPE_CHECKING, cast
  from airflow.exceptions import AirflowException, AirflowProviderDeprecationWarning
  from airflow.operators.python import ShortCircuitOperator
  from airflow.providers.amazon.aws.hooks.appflow import AppflowHook
  from airflow.providers.amazon.aws.operators.base_aws import AwsBaseOperator
  from airflow.providers.amazon.aws.utils import datetime_to_epoch_ms
  from airflow.providers.amazon.aws.utils.mixins import AwsBaseHookMixin, AwsHookParams, aws_template_fields
label_desc: Use image node_id 1 to create a new AppflowRunOperator object from inherited base classes: AppflowBaseOperator with example: obj = AppflowRunOperator(flow_name, source, poll_interval, wait_for_completion)