def _handle(self, msg):
fn = getattr(self, "_%s" % msg[0])
# Commit after each message to ensure the next message handler
# doesn't see a stale transaction
with transaction.commit_on_success():
fn(*msg[1], **msg[2])
job_scheduler.py 文件源码
python
阅读 28
收藏 0
点赞 0
评论 0
评论列表
文章目录