[ceph.git] / ceph / src / pybind / mgr / dashboard / controllers / task.py

# -*- coding: utf-8 -*-
from __future__ import absolute_import

from . import ApiController, RESTController
from ..tools import TaskManager
from ..services import progress


@ApiController('/task')
class Task(RESTController):
    def list(self, name=None):
        executing_t, finished_t = TaskManager.list_serializable(name)

        e, f = progress.get_progress_tasks()
        executing_t.extend(e)
        finished_t.extend(f)

        executing_t.sort(key=lambda t: t['begin_time'], reverse=True)
        finished_t.sort(key=lambda t: t['end_time'], reverse=True)

        return {
            'executing_tasks': executing_t,
            'finished_tasks': finished_t
        }
Commit	Line	Data
11fdf7f2 TL	1	# -- coding: utf-8 --
	2	from __future__ import absolute_import
	3
	4	from . import ApiController, RESTController
	5	from ..tools import TaskManager
9f95a23c	6	from ..services import progress
11fdf7f2 TL	7
	8
	9	@ApiController('/task')
	10	class Task(RESTController):
	11	def list(self, name=None):
	12	executing_t, finished_t = TaskManager.list_serializable(name)
9f95a23c TL	13
	14	e, f = progress.get_progress_tasks()
	15	executing_t.extend(e)
	16	finished_t.extend(f)
	17
	18	executing_t.sort(key=lambda t: t['begin_time'], reverse=True)
	19	finished_t.sort(key=lambda t: t['end_time'], reverse=True)
	20
11fdf7f2 TL	21	return {
	22	'executing_tasks': executing_t,
	23	'finished_tasks': finished_t
	24	}