fix: close write object stream always (#1661)

chandra-siri · web-flow · commit 4a609a4b3f4b · 2025-12-11T11:41:17.000+05:30
fix: close write object stream always. 

otherwise Task will remain for long time until GC kills it and it'll
throw this `"Task was destroyed but it is pending!"`
diff --git a/google/cloud/storage/_experimental/asyncio/async_appendable_object_writer.py b/google/cloud/storage/_experimental/asyncio/async_appendable_object_writer.py
@@ -267,7 +267,8 @@ async def close(self, finalize_on_close=False) -> Union[int, _storage_v2.Object]
             await self.finalize()
         else:
             await self.flush()
-            await self.write_obj_stream.close()
+
+        await self.write_obj_stream.close()
 
         self._is_stream_open = False
         self.offset = None
diff --git a/tests/unit/asyncio/test_async_appendable_object_writer.py b/tests/unit/asyncio/test_async_appendable_object_writer.py
@@ -313,7 +313,7 @@ async def test_finalize_on_close(mock_write_object_stream, mock_client):
     result = await writer.close(finalize_on_close=True)
 
     # Assert
-    mock_stream.close.assert_not_awaited()  # Based on new implementation
+    mock_stream.close.assert_awaited_once()
     assert not writer._is_stream_open
     assert writer.offset is None
     assert writer.object_resource == mock_resource
