@@ -78,10 +78,15 @@ def octue_cli(id, logger_uri, log_level, force_reset):
78
78
79
79
@octue_cli .group ()
80
80
def question ():
81
- """Ask and interact with questions to an Octue Twined data service."""
81
+ """Ask a new question to an Octue Twined data service or interact with a previous question ."""
82
82
83
83
84
- @question .command ()
84
+ @question .group ()
85
+ def ask ():
86
+ """Ask a new question to an Octue Twined data service."""
87
+
88
+
89
+ @ask .command ()
85
90
@click .argument ("sruid" , type = str )
86
91
@click .option (
87
92
"-i" ,
@@ -112,7 +117,7 @@ def question():
112
117
help = "If provided, ask the question and detach (the result and other events can be retrieved from the event store "
113
118
"later)." ,
114
119
)
115
- def ask (sruid , input_values , input_manifest , project_name , asynchronous ):
120
+ def remote (sruid , input_values , input_manifest , project_name , asynchronous ):
116
121
"""Ask a question to a remote Octue Twined service.
117
122
118
123
SRUID should be a valid service revision unique identifier for an existing Octue Twined service
@@ -142,7 +147,7 @@ def ask(sruid, input_values, input_manifest, project_name, asynchronous):
142
147
return json .dumps (answer , cls = OctueJSONEncoder )
143
148
144
149
145
- @question .command ()
150
+ @ask .command ()
146
151
@click .option (
147
152
"-i" ,
148
153
"--input-values" ,
@@ -166,7 +171,7 @@ def ask(sruid, input_values, input_manifest, project_name, asynchronous):
166
171
"`OCTUE_SERVICE_CONFIGURATION_PATH` environment variable is used if present, otherwise the local path `octue.yaml` "
167
172
"is used." ,
168
173
)
169
- def ask_local (input_values , input_manifest , service_config ):
174
+ def local (input_values , input_manifest , service_config ):
170
175
"""Ask a question to a local Octue Twined service."""
171
176
if input_values :
172
177
input_values = json .loads (input_values , cls = OctueJSONDecoder )
0 commit comments