

def run(self):
    d = Deferred()
    self.reactor.callLater(self.wait_seconds, d.callback, None)
    return d

dataset/ETHPy150Open ClusterHQ/flocker/benchmark/operations/wait.py WaitProbe.run/original