[Python] How do I delete a job from ARQ Redis

Discussão em 'Python' iniciado por Stack, Junho 24, 2025.

  1. Stack

    Stack Membro Participativo

    I'm trying to remove a scheduled job from ARQ (Python Redis job queue), but none of my approaches work. Here's what I've attempted:

    Attempt: 1

    arq_redis = await get_arq_redis()
    await arq_redis.delete_job(schedule.job_id)


    Attempt: 2

    arq_redis = await get_arq_redis()
    queued_jobs = await arq_redis.queued_jobs()

    for job in queued_jobs:
    if job.job_id == my_desired_job_id:
    await job.delete()


    Attempt: 3

    for job in queued_jobs:
    if job.job_id == schedule.job_id:
    await job.abort()


    Attempt: 4

    for job_def in queued_jobs:
    if job_def.job_id == schedule.job_id:
    job = await arq_redis.get_job(job_def.job_id)
    await job.abort()

    Continue reading...

Compartilhe esta Página