Skip to content

Commit

Permalink
update log statement and version bump
Browse files Browse the repository at this point in the history
  • Loading branch information
sideshowdave7 committed Mar 14, 2017
1 parent ea01e0e commit 993b47e
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 4 deletions.
2 changes: 1 addition & 1 deletion eventmq/__init__.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
__author__ = 'EventMQ Contributors'
__version__ = '0.3.2'
__version__ = '0.3.3'

PROTOCOL_VERSION = 'eMQP/1.0'

Expand Down
10 changes: 8 additions & 2 deletions eventmq/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,9 @@ def run(self):
try:
run_setup(conf.SETUP_PATH, conf.SETUP_CALLABLE)
except Exception as e:
logger.warning('Unable to complete setup: ' + str(e))
logger.warning('Unable to complete setup task ({}.{}): {}'
.format(conf.SETUP_PATH,
conf.SETUP_CALLABLE, str(e)))

import zmq
zmq.Context.instance().term()
Expand Down Expand Up @@ -167,7 +169,11 @@ def _run(payload):


def run_setup(setup_path, setup_callable):
logger.debug("Running setup for worker id {}".format(os.getpid()))
logger.debug("Running setup ({}.{}) for worker id {}".format(
setup_path,
setup_callable,
os.getpid()))

if ":" in setup_path:
_pkgsplit = setup_path.split(':')
s_setup_package = _pkgsplit[0]
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

setup(
name='eventmq',
version='0.3.2',
version='0.3.3',
description='EventMQ job execution and messaging system based on ZeroMQ',
packages=find_packages(),
install_requires=['pyzmq==15.4.0',
Expand Down

0 comments on commit 993b47e

Please sign in to comment.