Skip to content

Commit 4b58507

Browse files
committed
comment wording + add get_raw to DSSMLTaskQueues
1 parent b056163 commit 4b58507

2 files changed

Lines changed: 11 additions & 8 deletions

File tree

dataikuapi/dss/ml.py

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3427,10 +3427,13 @@ def guess(self, prediction_type=None, reguess_level=None):
34273427

34283428
class DSSMLTaskQueues(object):
34293429
"""
3430-
Object containing a list of MLTask queues
3430+
Iterable listing of MLTask queues
34313431
"""
3432-
def __init__(self, queues):
3433-
self.queues = queues
3432+
def __init__(self, data):
3433+
self.data = data
34343434

34353435
def __iter__(self):
3436-
return self.queues.__iter__()
3436+
return self.data["queues"].__iter__()
3437+
3438+
def get_raw(self):
3439+
return self.data

dataikuapi/dss/project.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -593,13 +593,13 @@ def get_ml_task(self, analysis_id, mltask_id):
593593

594594
def list_mltask_queues(self):
595595
"""
596-
List ML task queues in this project
596+
List non-empty ML task queues in this project
597597
598-
:returns: a :class:`DSSMLTaskQueues` object containing a list of queues as dicts
598+
:returns: an iterable :class:`DSSMLTaskQueues` listing of MLTask queues (each a dict)
599599
:rtype: :class:`DSSMLTaskQueues`
600600
"""
601-
ref = self.client._perform_json("GET", "/projects/%s/models/labs/mltask-queues" % self.project_key)
602-
return DSSMLTaskQueues(ref["queues"])
601+
data = self.client._perform_json("GET", "/projects/%s/models/labs/mltask-queues" % self.project_key)
602+
return DSSMLTaskQueues(data)
603603

604604
def create_analysis(self, input_dataset):
605605
"""

0 commit comments

Comments
 (0)