diff options
| author | David Hurst | 2017-07-20 23:51:43 -0600 |
|---|---|---|
| committer | GitHub | 2017-07-20 23:51:43 -0600 |
| commit | c2ce431de1079f1a2a70dd0a08b0282bcbfe389b (patch) | |
| tree | 070af7f1faf32071afc81674bde1310aaf08c632 | |
| parent | feb37e7f716fd69692777ad501fe5ddf5ad7c28f (diff) | |
| parent | 0f77842438147dbcc638ab6092a190162f97eb3a (diff) | |
| download | eventmq-c2ce431de1079f1a2a70dd0a08b0282bcbfe389b.tar.gz eventmq-c2ce431de1079f1a2a70dd0a08b0282bcbfe389b.zip | |
Merge pull request #51 from sideshowdave7/master
Remove Jobs in flight logging as its too spammy.
| -rw-r--r-- | eventmq/__init__.py | 2 | ||||
| -rw-r--r-- | eventmq/jobmanager.py | 4 | ||||
| -rw-r--r-- | setup.py | 2 |
3 files changed, 2 insertions, 6 deletions
diff --git a/eventmq/__init__.py b/eventmq/__init__.py index 37a6afb..a02a091 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.8' | 2 | __version__ = '0.3.4.9' |
| 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 4bd4ccb..c904d99 100644 --- a/eventmq/jobmanager.py +++ b/eventmq/jobmanager.py | |||
| @@ -390,10 +390,6 @@ class JobManager(HeartbeatMixin, EMQPService): | |||
| 390 | necessary | 390 | necessary |
| 391 | """ | 391 | """ |
| 392 | # Kill workers that aren't alive | 392 | # Kill workers that aren't alive |
| 393 | if conf.SUPER_DEBUG: | ||
| 394 | logger.debug("Jobs in flight: {}".format(len(self.jobs_in_flight))) | ||
| 395 | logger.debug("Total requests: {}".format(self.total_requests)) | ||
| 396 | logger.debug("Total ready sent: {}".format(self.total_ready_sent)) | ||
| 397 | try: | 393 | try: |
| 398 | [self.kill_worker(w.pid, signal.SIGKILL) for w in self.workers | 394 | [self.kill_worker(w.pid, signal.SIGKILL) for w in self.workers |
| 399 | if not w.is_alive] | 395 | if not w.is_alive] |
| @@ -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.8', | 10 | version='0.3.4.9', |
| 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', |