Hello :)
I'm not being able to find a running job with Exq.Api.find_job.
Is this expected?
Reproduction steps
- I have the following config:
config :exq,
name: Exq,
queues: ["default"]
- I have the following worker
defmodule TestWorker do
def perform do
job =
Exq.worker_job()
|> IO.inspect()
:timer.sleep(50000)
raise "error"
end
end
-
I enqueue the job {:ok, job_id} = Exq.enqueue(Exq, "default", TestWorker, [])
-
While the job is running I run Exq.Api.find_job(Exq.Api, "default", job_id) and it returns {:ok, nil}
Hello :)
I'm not being able to find a running job with
Exq.Api.find_job.Is this expected?
Reproduction steps
I enqueue the job
{:ok, job_id} = Exq.enqueue(Exq, "default", TestWorker, [])While the job is running I run
Exq.Api.find_job(Exq.Api, "default", job_id)and it returns{:ok, nil}