Skip to content

Commit 46253bc

Browse files
committed
Run callbacks in threads
1 parent f710e32 commit 46253bc

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

py/selenium/webdriver/remote/websocket_connection.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,8 +60,9 @@ def execute(self, command):
6060
logger.debug(f"-> {data}"[: self._max_log_message_size])
6161
self._ws.send(data)
6262

63-
self._wait_until(lambda: self._id in self._messages)
64-
response = self._messages.pop(self._id)
63+
current_id = self._id
64+
self._wait_until(lambda: current_id in self._messages)
65+
response = self._messages.pop(current_id)
6566

6667
if "error" in response:
6768
raise Exception(response["error"])
@@ -131,7 +132,7 @@ def _process_message(self, message):
131132
if "method" in message:
132133
params = message["params"]
133134
for callback in self.callbacks.get(message["method"], []):
134-
callback(params)
135+
Thread(target=callback, args=(params,)).start()
135136

136137
def _wait_until(self, condition):
137138
timeout = self._response_wait_timeout

0 commit comments

Comments
 (0)