aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDavid Hurst2017-07-19 14:01:17 -0600
committerDavid Hurst2017-07-20 10:04:52 -0600
commita4f127048d7b97a259e66a28cadee77140080e69 (patch)
tree94e9522957e4f8efd59f83b1bf5db2e3f537b8d1
parentc8840d93bb8be245b74e9d98174c1c6f2ec44ac2 (diff)
downloadeventmq-a4f127048d7b97a259e66a28cadee77140080e69.tar.gz
eventmq-a4f127048d7b97a259e66a28cadee77140080e69.zip
Version bump to 0.3.4.8
-rw-r--r--eventmq/__init__.py2
-rw-r--r--eventmq/jobmanager.py8
-rw-r--r--setup.py2
3 files changed, 8 insertions, 4 deletions
diff --git a/eventmq/__init__.py b/eventmq/__init__.py
index 2d9ae34..37a6afb 100644
--- a/eventmq/__init__.py
+++ b/eventmq/__init__.py
@@ -1,5 +1,5 @@
1__author__ = 'EventMQ Contributors' 1__author__ = 'EventMQ Contributors'
2__version__ = '0.3.4.7' 2__version__ = '0.3.4.8'
3 3
4PROTOCOL_VERSION = 'eMQP/1.0' 4PROTOCOL_VERSION = 'eMQP/1.0'
5 5
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index 57c05a4..4bd4ccb 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -146,9 +146,13 @@ class JobManager(HeartbeatMixin, EMQPService):
146 Starts the actual event loop. Usually called by :meth:`start` 146 Starts the actual event loop. Usually called by :meth:`start`
147 """ 147 """
148 # Acknowledgment has come 148 # Acknowledgment has come
149 # When the job manager unexpectedly disconnects from the router and
150 # reconnects it needs to send a ready for each previously available
151 # worker.
149 # Send a READY for each previously available worker 152 # Send a READY for each previously available worker
150 for _ in self.workers: 153 if hasattr(self, '_workers'):
151 self.send_ready() 154 for _ in self._workers:
155 self.send_ready()
152 156
153 self.status = STATUS.running 157 self.status = STATUS.running
154 158
diff --git a/setup.py b/setup.py
index 3ecc478..ad91149 100644
--- a/setup.py
+++ b/setup.py
@@ -7,7 +7,7 @@ from setuptools import find_packages, setup
7 7
8setup( 8setup(
9 name='eventmq', 9 name='eventmq',
10 version='0.3.4.7', 10 version='0.3.4.8',
11 description='EventMQ job execution and messaging system based on ZeroMQ', 11 description='EventMQ job execution and messaging system based on ZeroMQ',
12 packages=find_packages(), 12 packages=find_packages(),
13 install_requires=['pyzmq==15.4.0', 13 install_requires=['pyzmq==15.4.0',