Add job_id to Logger metadata for tracking

akira · Aug 22, 2024 · 318d084 · 318d084
1 parent 7e35598
commit 318d084
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/exq/worker/server.ex b/lib/exq/worker/server.ex
@@ -21,6 +21,7 @@ defmodule Exq.Worker.Server do
   alias Exq.Middleware.Server, as: Middleware
   alias Exq.Middleware.Pipeline
   alias Exq.Worker.Metadata
+  require Logger
 
   defmodule State do
     defstruct job_serialized: nil,
@@ -172,6 +173,7 @@ defmodule Exq.Worker.Server do
     {:ok, pid} =
       Task.start_link(fn ->
         :ok = Metadata.associate(metadata, self(), job)
+        Logger.metadata(job_id: job.jid)
         result = apply(worker_module, :perform, job.args)
         GenServer.cast(worker, {:done, result})
       end)