hotfix: make job reporter safer

fastrepl · Oct 28, 2024 · 42cd1d4 · 42cd1d4
1 parent bfd0ad7
commit 42cd1d4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/lib/canary/workers/job_reporter.ex b/core/lib/canary/workers/job_reporter.ex
@@ -21,9 +21,9 @@ defmodule Canary.Workers.JobReporter do
         _opts
       )
       when event in [:start, :stop, :exception] and worker in @processors do
-    source = Ash.get!(Source, args["source_id"])
-
     try do
+      source = Ash.get!(Source, args["source_id"])
+
       case event do
         :start ->
           Source.update_state(source, :running)