Skip to content

Commit f30f610

Browse files
author
Istemi Ekin Akkus
committed
function worker: fix addressable function stopping when blocking for new sessin update messages
1 parent c46055b commit f30f610

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

FunctionWorker/python/SessionHelperThread.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -235,6 +235,7 @@ def _store_message(self, msg):
235235
self._message_queue.put(msg)
236236

237237
def _handle_special_message(self, msg):
238+
#self._logger.debug("[SessionHelperThread] Special message: " + str(msg))
238239
action = msg["action"]
239240

240241
if action == "--stop":
@@ -321,3 +322,5 @@ def _cleanup(self):
321322

322323
def shutdown(self):
323324
self._is_running = False
325+
# put a dummy message to get out of any blocking 'self.get_messages()' call
326+
self._message_queue.put(None)

0 commit comments

Comments
 (0)