Commit 18f947a2 authored by André Anjos's avatar André Anjos 💬
Browse files

Merge branch '26_fix_end_index_handling_in_write' into 'master'

[execution][messagehandlers] Fix write end_data_index handling in LoopMessageHandler

See merge request !60
parents 6de025dc 9c5b097c
Pipeline #33728 passed with stages
in 9 minutes and 45 seconds
......@@ -416,11 +416,17 @@ class LoopMessageHandler(MessageHandler):
def write(self, end_data_index):
""" Trigger a write on the output"""
try:
end_data_index = int(end_data_index)
except ValueError:
logger.warning("recv: wrt invalid value {}".format(end_data_index))
end_data_index = end_data_index.decode("utf-8")
if end_data_index != "None":
try:
end_data_index = int(end_data_index)
except ValueError:
logger.warning("recv: wrt invalid value {}".format(end_data_index))
end_data_index = None
else:
end_data_index = None
logger.debug("recv: wrt {}".format(end_data_index))
try:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment