[PYTHON] Even if you cancel or delete the job in the queue, the process running on the worker does not stop (2)

background

I found a better way than the previous article

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

Set to RedisClient when erasing a job

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)

Confirmed on the processing side

from rq import get_current_job

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

reference

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