def METHOD_NAME(
    action: str,
    task_trigger: SimpleHttpOperator,
    timeout: timedelta,
    poke_interval: int = REFRESH_POKE_INTERVAL,
) -> HttpSensor:
    return HttpSensor(
        task_id=f"wait_for_{action.lower()}",
        http_conn_id="data_refresh",
        endpoint=XCOM_PULL_TEMPLATE.format(task_trigger.task_id, "return_value"),
        method="GET",
        response_check=response_check_wait_for_completion,
        mode="reschedule",
        poke_interval=poke_interval,
        timeout=timeout.total_seconds(),
    )