diff --git a/packages/database-jobs/deploy/schemas/app_jobs/procedures/add_job.sql b/packages/database-jobs/deploy/schemas/app_jobs/procedures/add_job.sql
index 3c9598799..1645b1a5a 100644
--- a/packages/database-jobs/deploy/schemas/app_jobs/procedures/add_job.sql
+++ b/packages/database-jobs/deploy/schemas/app_jobs/procedures/add_job.sql
@@ -19,6 +19,9 @@ CREATE FUNCTION app_jobs.add_job (
 DECLARE
   v_job app_jobs.jobs;
 BEGIN
+  -- Bake actor_id into payload
+  payload := (coalesce(payload, '{}'::json)::jsonb || jsonb_build_object('actor_id', jwt_public.current_user_id()))::json;
+
   IF job_key IS NOT NULL THEN
     -- Upsert job	
     INSERT INTO app_jobs.jobs (