Commit f87dffbb authored by Samuel GAIST's avatar Samuel GAIST
Browse files

[helpers] Update for new loop user types

parent 0ad3cc55
...@@ -263,7 +263,7 @@ def create_inputs_from_configuration( ...@@ -263,7 +263,7 @@ def create_inputs_from_configuration(
data_source = view.data_sources[details["output"]] data_source = view.data_sources[details["output"]]
if (algorithm.type == Algorithm.LEGACY) or ( if (algorithm.type == Algorithm.LEGACY) or (
(algorithm.type == Algorithm.SEQUENTIAL) (algorithm.is_sequential)
and (details["channel"] == config["channel"]) and (details["channel"] == config["channel"])
): ):
input = Input(name, algorithm.input_map[name], data_source) input = Input(name, algorithm.input_map[name], data_source)
...@@ -314,7 +314,7 @@ def create_inputs_from_configuration( ...@@ -314,7 +314,7 @@ def create_inputs_from_configuration(
raise IOError("cannot setup remote data source '%s'" % name) raise IOError("cannot setup remote data source '%s'" % name)
if (algorithm.type == Algorithm.LEGACY) or ( if (algorithm.type == Algorithm.LEGACY) or (
(algorithm.type == Algorithm.SEQUENTIAL) (algorithm.is_sequential)
and (details["channel"] == config["channel"]) and (details["channel"] == config["channel"])
): ):
input = Input(name, algorithm.input_map[name], data_source) input = Input(name, algorithm.input_map[name], data_source)
...@@ -342,7 +342,7 @@ def create_inputs_from_configuration( ...@@ -342,7 +342,7 @@ def create_inputs_from_configuration(
if algorithm.type == Algorithm.LEGACY: if algorithm.type == Algorithm.LEGACY:
input = _create_local_input(details) input = _create_local_input(details)
elif algorithm.type == Algorithm.SEQUENTIAL: elif algorithm.is_sequential:
if details["channel"] == config["channel"]: # synchronized if details["channel"] == config["channel"]: # synchronized
input = _create_local_input(details) input = _create_local_input(details)
else: else:
......
Supports Markdown
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