django現在のdjangoユーザーのために実行中/保留中のセロリタスクを取得

Question

現在ログインしているdjangoユーザーに対して実行中/保留中のセロリタスクをすべて取得する方法はありますか？私が試しているものの擬似コード：

@celery.task 
    def process_task(user, task_to_do): 
     #get all running or pending(queued) task for current user 
     user_tasks = user.get_task(status=PENDING or status=STARTED) 
     if not user_task: 
      #allow user to schedule additional task 
      process.... 
     else: 
      return "Your previous tasks is already running" 

Answer 1

これは一般的に難しい作業です。

まず、あなたのブローカーからそれらを取得しますinspecting of workers

inspector = app.control.inspect() 
scheduled = inspector.scheduled() 
reserved = inspector.reserved() 
active = inspector.active() 

セロリを実装する必要があります。ポイントは - ブローカーはユーザーに関する情報を保存しないので、をタスクkwargsに追加する必要があります。

user_task.delay(user=user)

あなたは結果にkwarg userによってthees機能から結果をフィルタリングできるようになりますたより： [{'worker1.example.com': [{'eta': '2010-06-07 09:07:52', 'priority': 0, 'request': { 'name': 'tasks.usertask', 'id': '1a7980ea-8b19-413e-91d2-0b74f3844c4d', 'args': '[]', 'kwargs': '{'ユーザー'： '7'}'}}, ...

ここでの問題 - それは、遅くなります。