Merge pull request #100 from kube-HPC/move_stop_to_end

move stop algorithm method invocation to the end of stop streaming

Author: golanha

hkube_python_wrapper/wrapper/algorunner.py

@@ -475,10 +475,6 @@ def _stopAlgorithm(self, options):
         else:
             self._stopped = True
             try:
-                method = self._getMethod('stop')
-                if (method is not None):
-                    method(options)
-
                 forceStop = options.get('forceStop', False)
                 if (forceStop is True):
                     log.info('stopping using force flag')
@@ -503,7 +499,9 @@ def stopping():
                         self._checkQueueSize(event='scale down')
                     else:
                         self._hkubeApi.stopStreaming(force=forceStop)
-
+                method = self._getMethod('stop')
+                if (method is not None):
+                    method(options)
                 if (self._runningStartThread):
                     self._runningStartThread.join()
                     log.info('Joined threads algorithm and stop algorithm')