diff --git a/docs/apache-airflow-providers-google/operators/cloud/dataflow.rst b/docs/apache-airflow-providers-google/operators/cloud/dataflow.rst
index 75b76760867eb..905bb5790bca5 100644
--- a/docs/apache-airflow-providers-google/operators/cloud/dataflow.rst
+++ b/docs/apache-airflow-providers-google/operators/cloud/dataflow.rst
@@ -306,26 +306,12 @@ When job is triggered asynchronously sensors may be used to run checks for speci
 
 :class:`~airflow.providers.google.cloud.sensors.dataflow.DataflowJobAutoScalingEventsSensor`.
 
-.. exampleinclude:: /../../tests/system/providers/google/cloud/dataflow/example_dataflow_native_python_async_deferrable.py
-    :language: python
-    :dedent: 4
-    :start-after: [START howto_sensor_wait_for_job_message_deferrable]
-    :end-before: [END howto_sensor_wait_for_job_message_defferable]
-
-:class:`~airflow.providers.google.cloud.sensors.dataflow.DataflowJobAutoScalingEventsSensor`.
-
 .. exampleinclude:: /../../tests/system/providers/google/cloud/dataflow/example_dataflow_native_python_async.py
     :language: python
     :dedent: 4
     :start-after: [START howto_sensor_wait_for_job_autoscaling_event]
     :end-before: [END howto_sensor_wait_for_job_autoscaling_event]
 
-.. exampleinclude:: /../../tests/system/providers/google/cloud/dataflow/example_dataflow_native_python_async_deferrable.py
-    :language: python
-    :dedent: 4
-    :start-after: [START howto_sensor_wait_for_job_autoscaling_event_deferrable]
-    :end-before: [END howto_sensor_wait_for_job_autoscaling_event_deferrable]
-
 Reference
 ^^^^^^^^^
 
diff --git a/tests/system/providers/google/cloud/dataflow/example_dataflow_go.py b/tests/system/providers/google/cloud/dataflow/example_dataflow_go.py
index 65980a250cf31..71985a2f835f7 100644
--- a/tests/system/providers/google/cloud/dataflow/example_dataflow_go.py
+++ b/tests/system/providers/google/cloud/dataflow/example_dataflow_go.py
@@ -128,14 +128,6 @@ def check_autoscaling_event(autoscaling_events: list[dict]) -> bool:
         fail_on_terminal_state=False,
     )
 
-    wait_for_go_job_async_autoscaling_event_deferred = DataflowJobAutoScalingEventsSensor(
-        task_id="wait_for_go_job_async_autoscaling_event_deferred",
-        job_id="{{task_instance.xcom_pull('start_go_pipeline_dataflow_runner')['dataflow_job_id']}}",
-        location=LOCATION,
-        fail_on_terminal_state=False,
-        deferrable=True,
-    )
-
     delete_bucket = GCSDeleteBucketOperator(
         task_id="delete_bucket", bucket_name=BUCKET_NAME, trigger_rule=TriggerRule.ALL_DONE
     )
@@ -150,7 +142,6 @@ def check_autoscaling_event(autoscaling_events: list[dict]) -> bool:
             wait_for_go_job_async_done,
             wait_for_go_job_async_message,
             wait_for_go_job_async_autoscaling_event,
-            wait_for_go_job_async_autoscaling_event_deferred,
         ]
         # TEST TEARDOWN
         >> delete_bucket