Skip to content

Commit af15dd8

Browse files
committed
add run_queue param to train
1 parent 9dc676d commit af15dd8

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

dataikuapi/dss/ml.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3155,7 +3155,7 @@ def get_settings(self):
31553155
else:
31563156
return DSSClusteringMLTaskSettings(self.client, self.project_key, self.analysis_id, self.mltask_id, settings)
31573157

3158-
def train(self, session_name=None, session_description=None):
3158+
def train(self, session_name=None, session_description=None, run_queue=False):
31593159
"""
31603160
Trains models for this ML Task
31613161
@@ -3173,7 +3173,7 @@ def train(self, session_name=None, session_description=None):
31733173
:return: A list of model identifiers
31743174
:rtype: list of strings
31753175
"""
3176-
train_ret = self.start_train(session_name, session_description)
3176+
train_ret = self.start_train(session_name, session_description, run_queue)
31773177
self.wait_train_complete()
31783178
return self.get_trained_models_ids(session_id = train_ret["sessionId"])
31793179

@@ -3202,7 +3202,7 @@ def ensemble(self, model_ids=None, method=None):
32023202
return train_ret
32033203

32043204

3205-
def start_train(self, session_name=None, session_description=None):
3205+
def start_train(self, session_name=None, session_description=None, run_queue=False):
32063206
"""
32073207
Starts asynchronously a new train session for this ML Task.
32083208
@@ -3213,7 +3213,8 @@ def start_train(self, session_name=None, session_description=None):
32133213
"""
32143214
session_info = {
32153215
"sessionName" : session_name,
3216-
"sessionDescription" : session_description
3216+
"sessionDescription" : session_description,
3217+
"runQueue": run_queue
32173218
}
32183219

32193220
return self.client._perform_json(

0 commit comments

Comments
 (0)