@@ -32,7 +32,8 @@ createJobTableQuery tname = "CREATE TABLE " <> tname <>
3232createNotificationTrigger :: TableName -> Query
3333createNotificationTrigger tname = "create or replace function " <> fnName <> "() returns trigger as $$" <>
3434 "begin \n" <>
35− " perform pg_notify('" <> pgEventName tname <> "', row_to_json(new)::text); \n" <>
35+ " perform pg_notify('" <> pgEventName tname <> "', \n" <>
36+ " json_build_object('id', new.id, 'run_at', new.run_at, 'locked_at', new.locked_at)::text); \n" <>
3637 " return new; \n" <>
3738 "end; \n" <>
3839 "$$ language plpgsql;" <>