From fa0b67fc0b347ace27ef28d8a4a869823c3226cd Mon Sep 17 00:00:00 2001 From: PoAn Yang Date: Thu, 16 Jul 2026 13:59:35 +0900 Subject: [PATCH] Fix Apache Beam hook type error with mypy 2.2.0 typeshed Signed-off-by: PoAn Yang --- .../apache/beam/src/airflow/providers/apache/beam/hooks/beam.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/providers/apache/beam/src/airflow/providers/apache/beam/hooks/beam.py b/providers/apache/beam/src/airflow/providers/apache/beam/hooks/beam.py index 9dd36bd25a7b6..ae44d7f42bcaf 100644 --- a/providers/apache/beam/src/airflow/providers/apache/beam/hooks/beam.py +++ b/providers/apache/beam/src/airflow/providers/apache/beam/hooks/beam.py @@ -178,7 +178,7 @@ def run_beam_command( ) # Waits for Apache Beam pipeline to complete. log.info("Start waiting for Apache Beam process to complete.") - reads = [proc.stderr, proc.stdout] + reads = [fd for fd in (proc.stderr, proc.stdout) if fd is not None] while True: # Wait for at least one available fd. readable_fds, _, _ = select.select(reads, [], [], 5)