Add version printing to start of apps

eventmq/jobmanager.py

@@ -28,6 +28,7 @@
 
 import zmq
 
+from . import __version__
 from .constants import KBYE, STATUS
 from .poller import Poller, POLLIN
 from .sender import Sender
@@ -83,7 +84,8 @@ def __init__(self, override_settings=None, skip_signal=False, *args,
         #: referring to the logs.
         self.name = generate_device_name(conf.NAME)
 
-        logger.info('Initializing JobManager {}...'.format(self.name))
+        logger.info('Initializing JobManager {}...'.format(str(self.name)))
+        logger.info('JogManager version: ' + __version__)
 
         if not skip_signal:
             # handle any sighups by reloading config

eventmq/pub.py

@@ -19,7 +19,7 @@
 """
 import logging
 
-from . import exceptions, poller, publisher, receiver
+from . import __version__, exceptions, poller, publisher, receiver
 from .constants import STATUS
 from .settings import conf, reload_settings
 from .utils.classes import HeartbeatMixin
@@ -45,6 +45,9 @@ def __init__(self, override_settings=None, skip_signal=False, *args,
         self.override_settings = override_settings
         reload_settings('publisher', self.override_settings)
 
+        logger.info('Initiaizing publisher...')
+        logger.info('Publisher version: ' + __version__)
+
         super(Pub, self).__init__(*args, **kwargs)  # creates _meta
         self.poller = poller.Poller()
         self.incoming = receiver.Receiver()

eventmq/router.py

@@ -22,7 +22,7 @@
 import logging
 import signal
 
-from . import constants, exceptions, poller, receiver
+from . import __version__, constants, exceptions, poller, receiver
 from .constants import (
     CLIENT_TYPE, DISCONNECT, KBYE, PROTOCOL_VERSION, STATUS, STATUS_CMD,
     STATUS_COMMANDS
@@ -67,7 +67,8 @@ def __init__(self, override_settings=None, skip_signal=False, *args,
 
         self.name = generate_device_name(conf.NAME)
 
-        logger.info('Initializing Router %s...' % self.name)
+        logger.info('Initializing Router %s...' % str(self.name))
+        logger.info('Router version: ' + __version__)
 
         self.poller = poller.Poller()
 

eventmq/scheduler.py

@@ -28,6 +28,7 @@
 import redis
 from six import next
 
+from . import __version__
 from . import constants
 from .client.messages import send_request
 from .constants import KBYE, STATUS_CMD, STATUS_COMMANDS
@@ -74,12 +75,13 @@ def __init__(self, override_settings=None, skip_signal=False, *args,
 
         reload_settings('scheduler', self.override_settings)
 
-        logger.info('Initializing Scheduler...')
-
         super(Scheduler, self).__init__(*args, **kwargs)
 
         self.name = generate_device_name(conf.NAME)
 
+        logger.info('Initializing Scheduler... ' + str(self.name))
+        logger.info('Scheduler version: ' + __version__)
+
         self.frontend = Sender(conf.NAME)
         self._redis_server = None
 

eventmq/settings.py

@@ -50,7 +50,7 @@
 # for py2 since dict().items() is inefficient
 from future.utils import iteritems
 
-from . import constants, __version__
+from . import __version__, constants
 from .utils import tuplify