class_docstr: Sensor that always returns the return_value provided
  
  :param return_value: Set to true to mark the task as SKIPPED on failure
class_docstr_tok: ["Sensor","that","always","returns","the","return_value","provided",":","param","return_value",":","Set","to","true","to","mark","the","task","as","SKIPPED","on","failure"]
code: def execute(self, context: Context):
      started_at = timezone.utcnow()
      time_jump = self.params["time_jump"]
      while not self.poke(context):
          if time_jump:
              started_at -= time_jump
          if (
              timezone.utcnow() - started_at
          ).total_seconds() > self.timeout:
              if self.soft_fail:
                  raise AirflowSkipException("timeout")
              else:
                  raise AirflowSensorTimeout("timeout")
          time.sleep(self.poke_interval)
      self.log.info("Success criteria met. Exiting.")
  
file_path: airflow/tests/sensors/test_timeout_sensor.py
imports: from __future__ import annotations
  import time
  from datetime import timedelta
  from typing import TYPE_CHECKING
  import pytest
  from airflow.exceptions import AirflowSensorTimeout, AirflowSkipException
  from airflow.models.dag import DAG
  from airflow.sensors.base import BaseSensorOperator
  from airflow.utils import timezone
  from airflow.utils.timezone import datetime
label_desc: Use image node_id 3 for calling the TimeoutTestSensor obj's underlying member method code with example usage: obj.execute(context) without return types