def __init__(self):
# pid -> Job instance
# A pipeline that is backgrounded is always run in a SubProgramThunk? So
# you can wait for it once?
self.jobs = {}
微信
公众号
扫码关注公众号