Skip to content

Commit 1460357

Browse files
committed
Fix asyncio reactor for Python 3.9+
1 parent 56713fa commit 1460357

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cassandra/io/asyncioreactor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ def push(self, data):
173173

174174
async def _push_msg(self, chunks):
175175
# This lock ensures all chunks of a message are sequential in the Queue
176-
with await self._write_queue_lock:
176+
async with self._write_queue_lock:
177177
for chunk in chunks:
178178
self._write_queue.put_nowait(chunk)
179179

0 commit comments

Comments
 (0)