def notify(self, job):
with connection.cursor() as cur:
cur.execute('NOTIFY "{}", %s;'.format(self.notify_channel), [str(job.pk)])
微信
公众号
扫码关注公众号