def notify(self, job_id):
        cursor = connections[self.connection].cursor()
        cursor.execute("SELECT pg_notify(%s, %s);", (self.name, str(job_id)))
        cursor.close()
Notify postgresql channel when a job is enqueued
dataset/ETHPy150Open bretth/django-pq/pq/queue.py/Queue.notify