CeleryでRetryしたジョブを見つける方法

• 概要
• 環境
• サンプルコード
• 参考サイト

概要

Celery はリトライしたジョブは最終的に SUCCESS or FAILURE になるためリトライした RETRY のステータスのジョブは残りません

成功したがどのジョブがリトライしたかを調べたい場合には flower の API を使うと簡単です

環境

• Ubuntu 18.04
• Python 3.10.2
• flower 1.2

サンプルコード

import requests

api_root = 'http://localhost:5555/api'
task_api = '{}/tasks'.format(api_root)

res = requests.get(task_api)
tasks = res.json()
for task_id, info in tasks.items():
    if info['retries'] > 0:
        print(task_id)
        print(info)

参考サイト

• https://flower.readthedocs.io/en/latest/api.html