fix #49

tobymao · Dec 13, 2022 · 03a448a · 03a448a
1 parent 388436c
commit 03a448a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/saq/worker.py b/saq/worker.py
@@ -237,7 +237,7 @@ async def process(self) -> None:
             job.status = Status.ACTIVE
             job.attempts += 1
             await job.update()
-            context = {"worker": self, "job": job}
+            context = {**self.context, "job": job}
             await self._before_process(context)
             logger.info("Processing %s", job)