0
2つの別々のサーバーに2つのアプリケーションがあり、AとBと呼ばせてください。両方のアプリケーションでCeleryワーカーがアクティブになり、キュー（QueueAとQueueB）を分離します。別のキュー/ワーカーでCeleryのlink_errorコールバックを実行する
サーバBは、apply_asyncを使用してキューBにタスクをプッシュします。ここで
は、サーバBのタスクです：
@app.task(bind=True, queue="QueueB", name="name_on_server_A")
def taskForServerB():
# nothing is executed here
@app.task(bind=True)
def success(result):
print('Task succeeded')
@app.task(bind=True):
def failure(...):
print('task failed')
taskForServerB.s().apply_async(link=success.s(), link_error=failure.s())
サーバA、タスクを受信し、それを実行name_on_server_A作業に。正常に完了すると、successタスクがServerB上で正常に実行されますが、name_on_server_Aが失敗すると、タスクfailureは実行されません。代わりに、サーバーAはfailureという名前のタスクに対してNotRegisteredErrorをスローします。
紛失しているものがありますか？最初のタスクが呼び出されたServerBで失敗タスクを実行するにはどうすればよいですか？