diff options
| author | David Hurst | 2017-10-14 20:51:02 -0600 |
|---|---|---|
| committer | David Hurst | 2017-10-14 20:51:02 -0600 |
| commit | caaac2a469cd8d97bd01541b2d172614efe8cbfb (patch) | |
| tree | 92ec201e2235ff7aa1f8a6094a701127835cef24 | |
| parent | 235f125c3ca68f9835936dcde40eff2fb275dcd0 (diff) | |
| download | eventmq-caaac2a469cd8d97bd01541b2d172614efe8cbfb.tar.gz eventmq-caaac2a469cd8d97bd01541b2d172614efe8cbfb.zip | |
get rid of ready calls at very beginning of event loop
| -rw-r--r-- | eventmq/jobmanager.py | 9 |
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: |