Script execution
This commit is contained in:
@@ -113,9 +113,10 @@ stop_event = None
|
||||
parameter_queue = None
|
||||
statistics =None
|
||||
current_pipeline = None
|
||||
pipeline_port = None
|
||||
|
||||
def start_pipeline(name, parameters, port=DEFAULT_PIPELINE_PORT):
|
||||
global stop_event, parameter_queue, statistics, current_pipeline, parameter_queue, statistics
|
||||
global stop_event, parameter_queue, statistics, current_pipeline, parameter_queue, statistics, pipeline_port
|
||||
if name is None:
|
||||
raise Exception("Pipeline name undefined")
|
||||
stop_pipeline();
|
||||
|
||||
Reference in New Issue
Block a user