From 367930f0bdb5b4cddb7be9a7613ed9b2e1f4df7b Mon Sep 17 00:00:00 2001 From: Robert Johnson Date: Fri, 28 Jul 2017 04:09:05 -0700 Subject: [PATCH] add embed option for /v2/queue --- marathon/client.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/marathon/client.py b/marathon/client.py index 6a5269e..79dc540 100644 --- a/marathon/client.py +++ b/marathon/client.py @@ -668,13 +668,17 @@ def list_deployments(self): response = self._do_request('GET', '/v2/deployments') return self._parse_response(response, MarathonDeployment, is_list=True) - def list_queue(self): + def list_queue(self, embed_last_unused_offers=False): """List all the tasks queued up or waiting to be scheduled. :returns: list of queue items :rtype: list[:class:`marathon.models.queue.MarathonQueueItem`] """ - response = self._do_request('GET', '/v2/queue') + if embed_last_unused_offers: + params = {'embed': 'lastUnusedOffers'} + else: + params = {} + response = self._do_request('GET', '/v2/queue', params=params) return self._parse_response(response, MarathonQueueItem, is_list=True, resource_name='queue') def delete_deployment(self, deployment_id, force=False):