From 049d73f217dfc881b89be23bc23d33d995bdea42 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 21 Mar 2017 09:00:49 +0100
Subject: backport request() notification

---
 joblib.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/joblib.py b/joblib.py
index 8faf71f..d922405 100644
--- a/joblib.py
+++ b/joblib.py
@@ -66,6 +66,8 @@ class JobQueue(object):
                     ids.append(await insert.fetchval(jobtype,
                                                      json.dumps(pl),
                                                      pr))
+                await con.execute("SELECT pg_notify($1 || '_open', '')",
+                                  jobtype)
             if isinstance(payload, list):
                 return ids
             else:
-- 
cgit v1.3.1