Skip to content

Commit 6550f80

Browse files
authored
Merge pull request #300 from fruch/fix_asyncio_background
asyncioreactor: initial background_tasks set earlier
2 parents 6b82872 + 3de6a36 commit 6550f80

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

cassandra/io/asyncioreactor.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,7 @@ class AsyncioConnection(Connection):
8787

8888
def __init__(self, *args, **kwargs):
8989
Connection.__init__(self, *args, **kwargs)
90+
self._background_tasks = set()
9091

9192
self._connect_socket()
9293
self._socket.setblocking(0)
@@ -106,7 +107,7 @@ def __init__(self, *args, **kwargs):
106107
)
107108
self._send_options_message()
108109

109-
self._background_tasks = set()
110+
110111

111112
@classmethod
112113
def initialize_reactor(cls):

0 commit comments

Comments
 (0)