aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDavid Hurst2017-10-14 20:51:02 -0600
committerDavid Hurst2017-10-14 20:51:02 -0600
commitcaaac2a469cd8d97bd01541b2d172614efe8cbfb (patch)
tree92ec201e2235ff7aa1f8a6094a701127835cef24
parent235f125c3ca68f9835936dcde40eff2fb275dcd0 (diff)
downloadeventmq-caaac2a469cd8d97bd01541b2d172614efe8cbfb.tar.gz
eventmq-caaac2a469cd8d97bd01541b2d172614efe8cbfb.zip
get rid of ready calls at very beginning of event loop
-rw-r--r--eventmq/jobmanager.py9
1 files changed, 0 insertions, 9 deletions
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index 78a080b..f85bf66 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -146,15 +146,6 @@ class JobManager(HeartbeatMixin, EMQPService):
146 """ 146 """
147 Starts the actual event loop. Usually called by :meth:`start` 147 Starts the actual event loop. Usually called by :meth:`start`
148 """ 148 """
149 # Acknowledgment has come
150 # When the job manager unexpectedly disconnects from the router and
151 # reconnects it needs to send a ready for each previously available
152 # worker.
153 # Send a READY for each previously available worker
154 if hasattr(self, '_workers'):
155 for _ in self._workers:
156 self.send_ready()
157
158 self.status = STATUS.running 149 self.status = STATUS.running
159 150
160 try: 151 try: