Skip to content

Commit

Permalink
Set WorkerRunner.worker_state earlier in order to prevent potential r…
Browse files Browse the repository at this point in the history
…ace condition. Fixes #1500.
  • Loading branch information
heyman committed Aug 4, 2020
1 parent f5b89d7 commit 2f8e64e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion locust/runners.py
Original file line number Diff line number Diff line change
Expand Up @@ -605,14 +605,14 @@ def __init__(self, environment, master_host, master_port):
:param master_port: Port to use for connecting to the master
"""
super().__init__(environment)
self.worker_state = STATE_INIT
self.client_id = socket.gethostname() + "_" + uuid4().hex
self.master_host = master_host
self.master_port = master_port
self.client = rpc.Client(master_host, master_port, self.client_id)
self.greenlet.spawn(self.heartbeat).link_exception(greenlet_exception_handler)
self.greenlet.spawn(self.worker).link_exception(greenlet_exception_handler)
self.client.send(Message("client_ready", None, self.client_id))
self.worker_state = STATE_INIT
self.greenlet.spawn(self.stats_reporter).link_exception(greenlet_exception_handler)

# register listener for when all users have hatched, and report it to the master node
Expand Down

0 comments on commit 2f8e64e

Please sign in to comment.