Run job queue's createNotificationTrigger inside a single transaction

This fixes jobs sometimes not being picked up directly

IHP/Job/Queue.hs

@@ -113,14 +113,17 @@ pollForJob tableName pollInterval handleJob = do
             Concurrent.threadDelay pollIntervalWithJitter
 
 createNotificationTrigger :: Text -> Text
-createNotificationTrigger tableName = "CREATE OR REPLACE FUNCTION " <> functionName <> "() RETURNS TRIGGER AS $$"
+createNotificationTrigger tableName = ""
+        <> "BEGIN;\n"
+        <> "CREATE OR REPLACE FUNCTION " <> functionName <> "() RETURNS TRIGGER AS $$"
         <> "BEGIN\n"
         <> "    PERFORM pg_notify('" <> eventName tableName <> "', '');\n"
         <> "    RETURN new;"
         <> "END;\n"
         <> "$$ language plpgsql;"
         <> "DROP TRIGGER IF EXISTS " <> insertTriggerName <> " ON " <> tableName <> "; CREATE TRIGGER " <> insertTriggerName <> " AFTER INSERT ON \"" <> tableName <> "\" FOR EACH ROW WHEN (NEW.status = 'job_status_not_started' OR NEW.status = 'job_status_retry') EXECUTE PROCEDURE " <> functionName <> "();\n"
         <> "DROP TRIGGER IF EXISTS " <> updateTriggerName <> " ON " <> tableName <> "; CREATE TRIGGER " <> updateTriggerName <> " AFTER UPDATE ON \"" <> tableName <> "\" FOR EACH ROW WHEN (NEW.status = 'job_status_not_started' OR NEW.status = 'job_status_retry') EXECUTE PROCEDURE " <> functionName <> "();\n"
+        <> "COMMIT;"
     where
         functionName = "notify_job_queued_" <> tableName
         insertTriggerName = "did_insert_job_" <> tableName