Merge pull request #104 from kube-HPC/check_algorithm_is_populated

if init or start were not invoked before stop _algorithm may be None

hkube_python_wrapper/wrapper/algorunner.py

@@ -16,7 +16,7 @@
 from hkube_python_wrapper.communication.streaming.StreamingManager import StreamingManager
 from hkube_python_wrapper.util.queueImpl import Queue, Empty
 from hkube_python_wrapper.util.timerImpl import Timer
-from hkube_python_wrapper.util.logger import log ,algorithmLogger
+from hkube_python_wrapper.util.logger import log, algorithmLogger
 from hkube_python_wrapper.util.url_encode_impl import url_encode
 from hkube_python_wrapper.util.stdout_redirector import stdout_redirector
 import os
@@ -310,8 +310,9 @@ def _log_message(self, data):
             pass
 
     def _getMethod(self, name):
-        return self._algorithm.get(name)
-
+        if (self._algorithm):
+            return self._algorithm.get(name)
+        return None
     def _init(self, options):
         redirector = None
         try:

setup.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 2.5.0-dev10
+current_version = 2.6.0-dev1
 commit = False
 tag = False
 parse = (?P<major>\d+)\.(?P<minor>\d+)\.(?P<patch>\d+)(\-(?P<release>[a-z]+)(?P<build>\d+))?

setup.py

@@ -6,7 +6,7 @@
 
 here = os.path.abspath(os.path.dirname(__file__))
 
-VERSION = '2.5.0-dev10'
+VERSION = '2.6.0-dev1'