From d58add06b57bf859d3ffec3610768bad27d5425e Mon Sep 17 00:00:00 2001
From: Philip Abbet <philip.abbet@idiap.ch>
Date: Fri, 17 Mar 2017 15:01:03 +0100
Subject: [PATCH] Fix the 'Executor' class
---
beat/backend/python/executor.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/beat/backend/python/executor.py b/beat/backend/python/executor.py
index 9728e12..5ebbe30 100644
--- a/beat/backend/python/executor.py
+++ b/beat/backend/python/executor.py
@@ -102,11 +102,11 @@ class Executor(object):
for name, channel in self.data['inputs'].items():
group = self.input_list.group(channel)
if group is None:
- group = inputs.InputGroup(channel, (channel == main_channel),
+ group = inputs.RemoteInputGroup(channel, (channel == main_channel),
socket=self.socket)
self.input_list.add(group)
thisformat = self.algorithm.dataformats[self.algorithm.input_map[name]]
- group.add(inputs.Input(name, thisformat, self.socket))
+ group.add(inputs.RemoteInput(name, thisformat, self.socket))
logger.debug("Loaded input list with %d group(s) and %d input(s)",
self.input_list.nbGroups(), len(self.input_list))
@@ -115,7 +115,7 @@ class Executor(object):
self.output_list = outputs.OutputList()
for name, channel in self.data['outputs'].items():
thisformat = self.algorithm.dataformats[self.algorithm.output_map[name]]
- self.output_list.add(outputs.Output(name, thisformat, self.socket))
+ self.output_list.add(outputs.RemoteOutput(name, thisformat, self.socket))
logger.debug("Loaded output list with %d output(s)",
len(self.output_list))
@@ -126,7 +126,7 @@ class Executor(object):
# Retrieve dataformats in the JSON of the algorithm
analysis_format = self.algorithm.result_dataformat()
analysis_format.name = 'analysis:' + self.algorithm.name
- self.output_list.add(outputs.Output(name, analysis_format, self.socket))
+ self.output_list.add(outputs.RemoteOutput(name, analysis_format, self.socket))
logger.debug("Loaded output list for analyzer (1 single output)")
--
GitLab