code: def example_sensor_decorator():
      # [END instantiate_dag]
  
      # [START wait_function]
      # Using a sensor operator to wait for the upstream data to be ready.
      @task.sensor(poke_interval=60, timeout=3600, mode="reschedule")
      def wait_for_upstream() -> PokeReturnValue:
          return PokeReturnValue(is_done=True, xcom_value="xcom_value")
  
      # [END wait_function]
  
      # [START dummy_function]
      @task
      def dummy_operator() -> None:
          pass
  
      # [END dummy_function]
  
      # [START main_flow]
      wait_for_upstream() >> dummy_operator()
  
imports: from __future__ import annotations
  import pendulum
  from airflow.decorators import dag, task
  from airflow.sensors.base import PokeReturnValue
label_desc: Use image node_id 1 for calling a global function with example usage: example_sensor_decorator() and returns: PokeReturnValue