This is an automated email from the ASF dual-hosted git repository.
Lee-W 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 9bee629d207 Fix Apache Beam hook type error with mypy 2.2.0 typeshed
(#69946)
9bee629d207 is described below
commit 9bee629d20794d476aa8d7f9446f4891bf3dbddd
Author: PoAn Yang <[email protected]>
AuthorDate: Thu Jul 16 15:34:27 2026 +0900
Fix Apache Beam hook type error with mypy 2.2.0 typeshed (#69946)
Signed-off-by: PoAn Yang <[email protected]>
---
providers/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 9dd36bd25a7..ae44d7f42bc 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)
