(airflow) branch main updated: Cleanup type ignores (#53303)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 8f10a573f3f Cleanup type ignores (#53303)
8f10a573f3f is described below

commit 8f10a573f3f1279894be795c1e97da06d80aad4e
Author: mingdaoy <mingd...@gmail.com>
AuthorDate: Sun Jul 13 15:35:20 2025 +0800

    Cleanup type ignores (#53303)
---
 .../apache/beam/src/airflow/providers/apache/beam/triggers/beam.py  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 18ed42578c4..5778a126666 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 @@ class BeamPipelineBaseTrigger(BaseTrigger):
         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 @@ class BeamPythonPipelineTrigger(BeamPipelineBaseTrigger):
             },
         )
 
-    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 @@ class BeamJavaPipelineTrigger(BeamPipelineBaseTrigger):
             },
         )
 
-    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