diff --git a/slackbot/pipeline_commands.py b/slackbot/pipeline_commands.py index b1954792..d8bd277e 100644 --- a/slackbot/pipeline_commands.py +++ b/slackbot/pipeline_commands.py @@ -5,6 +5,7 @@ from bot_utils import replyto, extract_command, clear_queues, download_json, guess_run_type, latest_param_type, upload_param from kombu_helper import drain_messages, visible_messages, get_message, put_message from airflow_api import get_variable, set_variable, latest_dagrun_state, run_dag +from synaptor_commands import update_synaptor_params, run_synaptor @SeuronBot.on_message("show segmentation parameters", @@ -32,6 +33,8 @@ def on_update_parameters(msg): on_update_segmentation_parameters(msg) elif run_type == "inf_run": on_update_inference_parameters(msg) + elif run_type == "syn_run": + update_synaptor_params(msg) else: replyto(msg, "Cannot guess run type from input parameters, please be more specific") @@ -93,6 +96,8 @@ def on_run_pipeline(msg): on_run_inferences(msg) elif param_updated == 'seg_run': on_run_segmentations(msg) + elif param_updated == 'syn_run': + run_synaptor(msg) else: replyto(msg, "Do not understand the parameters, please upload them again")