aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDavid Hurst2017-07-20 23:51:43 -0600
committerGitHub2017-07-20 23:51:43 -0600
commitc2ce431de1079f1a2a70dd0a08b0282bcbfe389b (patch)
tree070af7f1faf32071afc81674bde1310aaf08c632
parentfeb37e7f716fd69692777ad501fe5ddf5ad7c28f (diff)
parent0f77842438147dbcc638ab6092a190162f97eb3a (diff)
downloadeventmq-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__.py2
-rw-r--r--eventmq/jobmanager.py4
-rw-r--r--setup.py2
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
4PROTOCOL_VERSION = 'eMQP/1.0' 4PROTOCOL_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]
diff --git a/setup.py b/setup.py
index ad91149..553c86b 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.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',