37e85590e8
Django settings now reside in the smart settings app. Celery settings now reside in the task manager app. Signed-off-by: Roberto Rosario <roberto.rosario@mayan-edms.com>
81 lines
2.5 KiB
Python
81 lines
2.5 KiB
Python
from __future__ import unicode_literals
|
|
|
|
from django.utils.translation import ugettext_lazy as _
|
|
|
|
from mayan.apps.common.apps import MayanAppConfig
|
|
from mayan.apps.common.html_widgets import TwoStateWidget
|
|
from mayan.apps.common.menus import menu_object, menu_secondary, menu_tools
|
|
from mayan.apps.navigation.classes import SourceColumn
|
|
|
|
from .classes import CeleryQueue, Task
|
|
from .links import (
|
|
link_queue_list, link_queue_active_task_list,
|
|
link_queue_scheduled_task_list, link_queue_reserved_task_list,
|
|
link_task_manager
|
|
)
|
|
from .settings import * # NOQA
|
|
|
|
|
|
class TaskManagerApp(MayanAppConfig):
|
|
app_namespace = 'task_manager'
|
|
app_url = 'task_manager'
|
|
has_tests = True
|
|
name = 'mayan.apps.task_manager'
|
|
verbose_name = _('Task manager')
|
|
|
|
def ready(self):
|
|
super(TaskManagerApp, self).ready()
|
|
|
|
CeleryQueue.initialize()
|
|
|
|
SourceColumn(
|
|
source=CeleryQueue, label=_('Label'), attribute='label'
|
|
)
|
|
SourceColumn(
|
|
source=CeleryQueue, label=_('Name'), attribute='name'
|
|
)
|
|
SourceColumn(
|
|
attribute='default_queue', label=_('Default queue?'),
|
|
source=CeleryQueue, widget=TwoStateWidget
|
|
)
|
|
SourceColumn(
|
|
attribute='transient', label=_('Is transient?'),
|
|
source=CeleryQueue, widget=TwoStateWidget
|
|
)
|
|
SourceColumn(
|
|
source=Task, label=_('Type'), attribute='task_type'
|
|
)
|
|
SourceColumn(
|
|
source=Task, label=_('Start time'), attribute='get_time_started'
|
|
)
|
|
SourceColumn(
|
|
source=Task, label=_('Host'),
|
|
func=lambda context: context['object'].kwargs['hostname']
|
|
)
|
|
SourceColumn(
|
|
source=Task, label=_('Arguments'),
|
|
func=lambda context: context['object'].kwargs['args']
|
|
)
|
|
SourceColumn(
|
|
source=Task, label=_('Keyword arguments'),
|
|
func=lambda context: context['object'].kwargs['kwargs']
|
|
)
|
|
SourceColumn(
|
|
source=Task, label=_('Worker process ID'),
|
|
func=lambda context: context['object'].kwargs['worker_pid']
|
|
)
|
|
|
|
menu_object.bind_links(
|
|
links=(
|
|
link_queue_active_task_list, link_queue_scheduled_task_list,
|
|
link_queue_reserved_task_list,
|
|
), sources=(CeleryQueue,)
|
|
)
|
|
|
|
menu_secondary.bind_links(
|
|
links=(link_queue_list,),
|
|
sources=(CeleryQueue, Task, 'task_manager:queue_list')
|
|
)
|
|
|
|
menu_tools.bind_links(links=(link_task_manager,))
|