def on_retry(self, exc, task_id, args, kwargs, einfo):
connection.close()
微信
公众号
扫码关注公众号
微信
公众号