From a6ca70204d4e667e7e0bdcb18221111238a92302 Mon Sep 17 00:00:00 2001 From: golanha Date: Thu, 14 Dec 2023 12:12:19 +0200 Subject: [PATCH 1/4] if init or start were not invoked before stop _algorithm may be None --- hkube_python_wrapper/wrapper/algorunner.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/hkube_python_wrapper/wrapper/algorunner.py b/hkube_python_wrapper/wrapper/algorunner.py index 3c3eca1e..e543f2a3 100644 --- a/hkube_python_wrapper/wrapper/algorunner.py +++ b/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,7 +310,10 @@ def _log_message(self, data): pass def _getMethod(self, name): - return self._algorithm.get(name) + if (self._algorithm): + return self._algorithm.get(name) + else: + return None def _init(self, options): redirector = None From d7a326a91afdc360f20a776bb015a1faabb2db10 Mon Sep 17 00:00:00 2001 From: golanha Date: Thu, 14 Dec 2023 12:37:48 +0200 Subject: [PATCH 2/4] 2.6 DEV --- setup.cfg | 2 +- setup.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/setup.cfg b/setup.cfg index db9b54d8..14006628 100644 --- a/setup.cfg +++ b/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\d+)\.(?P\d+)\.(?P\d+)(\-(?P[a-z]+)(?P\d+))? diff --git a/setup.py b/setup.py index ab8a0b7a..61f6dea4 100644 --- a/setup.py +++ b/setup.py @@ -6,7 +6,7 @@ here = os.path.abspath(os.path.dirname(__file__)) -VERSION = '2.5.0-dev10' +VERSION = '2.6.0-dev1' From ed3e13df4d9fd28e442d9bbf4bb8724ca8a0cccf Mon Sep 17 00:00:00 2001 From: golanha Date: Thu, 14 Dec 2023 12:39:55 +0200 Subject: [PATCH 3/4] pylint --- hkube_python_wrapper/wrapper/algorunner.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/hkube_python_wrapper/wrapper/algorunner.py b/hkube_python_wrapper/wrapper/algorunner.py index e543f2a3..ddf2b6fe 100644 --- a/hkube_python_wrapper/wrapper/algorunner.py +++ b/hkube_python_wrapper/wrapper/algorunner.py @@ -312,8 +312,6 @@ def _log_message(self, data): def _getMethod(self, name): if (self._algorithm): return self._algorithm.get(name) - else: - return None def _init(self, options): redirector = None From 5cf67533af80eb793dce1164263526c4b8b57f97 Mon Sep 17 00:00:00 2001 From: golanha Date: Thu, 14 Dec 2023 12:42:49 +0200 Subject: [PATCH 4/4] lint --- hkube_python_wrapper/wrapper/algorunner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hkube_python_wrapper/wrapper/algorunner.py b/hkube_python_wrapper/wrapper/algorunner.py index ddf2b6fe..4050afe3 100644 --- a/hkube_python_wrapper/wrapper/algorunner.py +++ b/hkube_python_wrapper/wrapper/algorunner.py @@ -312,7 +312,7 @@ def _log_message(self, data): def _getMethod(self, name): if (self._algorithm): return self._algorithm.get(name) - + return None def _init(self, options): redirector = None try: