backport request() notification1.2.0-threadsafe

1 files changed, 2 insertions, 0 deletions

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: