queueのjobをcancel、deleteしてもworkerで動いている処理は止まらない（２）

背景

前回記事より良い方法見つけた

• https://qiita.com/nakamumu/items/33fbca0b407aeec4112d

ジョブを消す時にRedisClientにset

from django_rq import get_queue
import os
import signal

q = get_queue()

job_id = ***
job = q.fetch_job(job_id)

job.connection.set(job.key + b':canceled', True, ex=30)

処理側で確認

from rq import get_current_job

def 処理():
  job = get_current_job()
  for item in items:
    if job.connection.get(job.key + b':canceled'):
      break

参考

• https://stackoverflow.com/questions/55244729/python-rq-how-to-pass-information-from-the-caller-to-the-worker