def restart(self, scheduler):
    for stealable in self.stealable.values():
        for s in stealable:
            s.clear()
    for s in self.stealable_all:
        s.clear()
    self.key_stealable.clear()
def restart(self, scheduler):
    for stealable in self.stealable.values():
        for s in stealable:
            s.clear()
    for s in self.stealable_all:
        s.clear()
    self.key_stealable.clear()