diff --git a/pkgs/development/python-modules/apache-beam/default.nix b/pkgs/development/python-modules/apache-beam/default.nix
index ff12480ceb25..74c693370cc5 100644
--- a/pkgs/development/python-modules/apache-beam/default.nix
+++ b/pkgs/development/python-modules/apache-beam/default.nix
@@ -59,19 +59,20 @@
   sqlalchemy,
   tenacity,
   testcontainers,
+  which,
   pythonAtLeast,
 }:
 
 buildPythonPackage rec {
   pname = "apache-beam";
-  version = "2.69.0";
+  version = "2.70.0";
   pyproject = true;
 
   src = fetchFromGitHub {
     owner = "apache";
     repo = "beam";
     tag = "v${version}";
-    hash = "sha256-7trrdGQ9jkzG+5/PyBMvHXjR0B4HjOxBhUuxXEcKkLg=";
+    hash = "sha256-sySHoknK2FmiAEOpRdF9i3vA6NvnDrZyBCghVoyEzLw=";
   };
 
   sourceRoot = "${src.name}/sdks/python";
@@ -170,6 +171,7 @@ buildPythonPackage rec {
     sqlalchemy
     tenacity
     testcontainers
+    which
   ];
 
   # Make sure we're running the tests for the actually installed
@@ -197,6 +199,9 @@ buildPythonPackage rec {
     #
     "apache_beam/io/external/xlang_jdbcio_it_test.py"
 
+    # AttributeError: '_TruncatingFileHandle' object has no attribute 'close'.
+    "apache_beam/ml/rag/ingestion/milvus_search_it_test.py"
+
     # These tests depend on the availability of specific servers backends.
     "apache_beam/runners/portability/flink_runner_test.py"
     "apache_beam/runners/portability/samza_runner_test.py"