diff --git a/providers/apache/beam/src/airflow/providers/apache/beam/triggers/beam.py b/providers/apache/beam/src/airflow/providers/apache/beam/triggers/beam.py
index 18ed42578c42a..5778a12666614 100644
--- a/providers/apache/beam/src/airflow/providers/apache/beam/triggers/beam.py
+++ b/providers/apache/beam/src/airflow/providers/apache/beam/triggers/beam.py
@@ -58,7 +58,7 @@ async def provide_gcs_tempfile(gcs_file, gcp_conn_id):
         create_tmp_file_call = gcs_hook.provide_file(object_url=gcs_file)
         tmp_gcs_file: IO[str] = await loop.run_in_executor(
             None,
-            contextlib.ExitStack().enter_context,  # type: ignore[arg-type]
+            contextlib.ExitStack().enter_context,
             create_tmp_file_call,
         )
         return tmp_gcs_file
@@ -126,7 +126,7 @@ def serialize(self) -> tuple[str, dict[str, Any]]:
             },
         )
 
-    async def run(self) -> AsyncIterator[TriggerEvent]:  # type: ignore[override]
+    async def run(self) -> AsyncIterator[TriggerEvent]:
         """Get current pipeline status and yields a TriggerEvent."""
         hook = self._get_async_hook(runner=self.runner)
 
@@ -201,7 +201,7 @@ def serialize(self) -> tuple[str, dict[str, Any]]:
             },
         )
 
-    async def run(self) -> AsyncIterator[TriggerEvent]:  # type: ignore[override]
+    async def run(self) -> AsyncIterator[TriggerEvent]:
         """Get current Java pipeline status and yields a TriggerEvent."""
         hook = self._get_async_hook(runner=self.runner)
         return_code = 0