1

セロリを使用して次のようなことをしたい: 1.タスクを開始するためにメッセージを送信し、タスクが開始されています労働者はそれを取り、行うことができます。

そして今、ワーカー関数からタスクを終了する方法がわかりません。私はこの呼び出された関数でそのようなことをしようとしていました:

if condition == true:
    revoke(current_task.request.id, terminate=True)

アプリでメッセージが送信されたときに、そのようにシグナル「task_revoke」を接続しようとしていました：

@task_revoked.connect
def do_something_when_revoke(terminated, signum, expired):
    do_something_here...

しかし、それは私にとってはうまくいきません。だから多分あなたはそれで私を助けて、私が間違っていること、またはそのようなことをする別の方法は何か教えてください:) 事前に感謝します

4

1 に答える 1

1

これを達成するためのより簡単な方法は、タスク自体の内部にそのロジックを実装することです。

  • タスクを取り消す必要はありません。何もしないでください。
  • タスクは、新しい更新されたタスクをキューに送信するだけです
于 2013-09-03T21:57:51.473 に答える