Merge branch 'develop' into master

* develop:
  Update CHANGELOG.md
  [hdfs] Make CliRawOutputBase.write return number of bytes written (#920)
  Bump the github-actions group with 2 updates (#919)

Author: ddelange

.github/workflows/release.yml

@@ -32,13 +32,13 @@ jobs:
         python -m build
 
     - name: Upload package distributions as release assets
-      uses: softprops/action-gh-release@v2.6.1
+      uses: softprops/action-gh-release@v3.0.0
       with:
         files: dist/*
 
     # https://github.com/pypa/gh-action-pypi-publish#trusted-publishing
     - name: Publish package distributions to PyPI
-      uses: pypa/gh-action-pypi-publish@v1.13.0
+      uses: pypa/gh-action-pypi-publish@v1.14.0
 
     - uses: apexskier/github-release-commenter@v1.4.1
       with:

CHANGELOG.md

@@ -1,3 +1,8 @@
+# 7.6.1, 2026-05-09
+
+- Bump the github-actions group with 2 updates (PR [#919](https://github.com/piskvorky/smart_open/pull/919), [@dependabot[bot]](https://github.com/apps/dependabot))
+- [hdfs] Make CliRawOutputBase.write return number of bytes written (PR [#920](https://github.com/piskvorky/smart_open/pull/920), [@LiuGuH](https://github.com/LiuGuH))
+
 # 7.6.0, 2026-04-13
 
 - Bump softprops/action-gh-release from 2.5.0 to 2.6.1 in the github-actions group (PR [#918](https://github.com/piskvorky/smart_open/pull/918), [@dependabot[bot]](https://github.com/apps/dependabot))

smart_open/hdfs.py

@@ -151,7 +151,17 @@ def seekable(self):
         return False
 
     def write(self, b):
-        self._sub.stdin.write(b)
+        """Write the given buffer to the underlying raw stream.
+
+        Returns the number of bytes written, as required by
+        :class:`io.RawIOBase`. Without this return value, callers that wrap
+        this stream and rely on the documented ``write`` contract (for
+        example, ``ray._private.external_storage._write_multiple_objects``,
+        which asserts ``written_bytes == payload_len``) fail with an
+        ``AssertionError`` because ``write`` would otherwise implicitly
+        return ``None``.
+        """
+        return self._sub.stdin.write(b)
 
     #
     # io.IOBase methods.

tests/test_hdfs.py

@@ -110,9 +110,15 @@ def test_write(schema):
     expected = 'мы в ответе за тех, кого приручили'
     mocked_cat = cat()
 
+    payload = expected.encode('utf-8')
     with mock.patch('subprocess.Popen', return_value=mocked_cat):
         with smart_open.hdfs.CliRawOutputBase(f'{schema}://dummy/url') as fout:
-            fout.write(expected.encode('utf-8'))
+            written = fout.write(payload)
+
+    # CliRawOutputBase implements io.RawIOBase, whose write() contract is to
+    # return the number of bytes written. Returning None breaks callers like
+    # ray._private.external_storage that assert on the return value.
+    assert written == len(payload)
 
     actual = mocked_cat.stdout.read().decode('utf-8')
     assert actual == expected