diff options
| author | David Hurst | 2017-07-19 14:01:17 -0600 |
|---|---|---|
| committer | David Hurst | 2017-07-20 10:04:52 -0600 |
| commit | a4f127048d7b97a259e66a28cadee77140080e69 (patch) | |
| tree | 94e9522957e4f8efd59f83b1bf5db2e3f537b8d1 | |
| parent | c8840d93bb8be245b74e9d98174c1c6f2ec44ac2 (diff) | |
| download | eventmq-a4f127048d7b97a259e66a28cadee77140080e69.tar.gz eventmq-a4f127048d7b97a259e66a28cadee77140080e69.zip | |
Version bump to 0.3.4.8
| -rw-r--r-- | eventmq/__init__.py | 2 | ||||
| -rw-r--r-- | eventmq/jobmanager.py | 8 | ||||
| -rw-r--r-- | setup.py | 2 |
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 | ||
| 4 | PROTOCOL_VERSION = 'eMQP/1.0' | 4 | PROTOCOL_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 | ||
| @@ -7,7 +7,7 @@ from setuptools import find_packages, setup | |||
| 7 | 7 | ||
| 8 | setup( | 8 | setup( |
| 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', |