This is an automated email from the ASF dual-hosted git repository.
absurdfarce pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-python-driver.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4842968f Fix `asyncio` reactor for Python 3.9+
4842968f is described below
commit 4842968f04fadb7b636cbed4c346994daf728471
Author: ramikg <[email protected]>
AuthorDate: Wed Feb 18 15:36:27 2026 +0200
Fix `asyncio` reactor for Python 3.9+
patch by ramikg; reviewed by Bret McGuire and Brad Schoening
reference: https://github.com/apache/cassandra-python-driver/pull/1270
---
cassandra/io/asyncioreactor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/cassandra/io/asyncioreactor.py b/cassandra/io/asyncioreactor.py
index 95f92e26..007e10d5 100644
--- a/cassandra/io/asyncioreactor.py
+++ b/cassandra/io/asyncioreactor.py
@@ -173,7 +173,7 @@ class AsyncioConnection(Connection):
async def _push_msg(self, chunks):
# This lock ensures all chunks of a message are sequential in the Queue
- with await self._write_queue_lock:
+ async with self._write_queue_lock:
for chunk in chunks:
self._write_queue.put_nowait(chunk)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
