class_docstr: Execute an AppFlow run after updating the filters to select only a single day.
  
  .. seealso::
      For more information on how to use this operator, take a look at the guide:
      :ref:`howto/operator:AppflowRunDailyOperator`
  
  :param source: The source name (Supported: salesforce)
  :param flow_name: The flow name
  :param source_field: The field name to apply filters
  :param filter_date: The date value (or template) to be used in filters.
  :param poll_interval: how often in seconds to check the query status
  :param wait_for_completion: whether to wait for the run to end to return
code: def _update_flow(self) -> None:
      if not self.filter_date_parsed:
          raise ValueError(
              f"Invalid filter_date argument parser value: {self.filter_date_parsed}"
          )
      if not self.source_field:
          raise ValueError(
              f"Invalid source_field argument value: {self.source_field}"
          )
      start_filter_date = self.filter_date_parsed - timedelta(
          milliseconds=1
      )
      end_filter_date = self.filter_date_parsed + timedelta(days=1)
      filter_task: TaskTypeDef = {
          "taskType": "Filter",
          "connectorOperator": {self.connector_type: "BETWEEN"},  # type: ignore
          "sourceFields": [self.source_field],
          "taskProperties": {
              "DATA_TYPE": "datetime",
              "LOWER_BOUND": str(
                  datetime_to_epoch_ms(start_filter_date)
              ),  # NOT inclusive
              "UPPER_BOUND": str(
                  datetime_to_epoch_ms(end_filter_date)
              ),  # NOT inclusive
          },
      }
      self.hook.update_flow_filter(
          flow_name=self.flow_name,
          filter_tasks=[filter_task],
          set_trigger_ondemand=True,
      )
  
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 2 for calling the AppflowRunDailyOperator obj's underlying member method code with example usage: obj._update_flow() without return types