

def _startCallback2(self, data):
    if (self.shutdown_trigger_id is not None):
        self.reportjobspeedloop = task.LoopingCall(self.reportJobSpeed)
        self.reportjobspeedloop.start(60)
        self.jobsloop = task.LoopingCall(self.executeJobs)
        self.jobsloop.start(1)
        if (self.aws_sdb_coordination_domain is not None):
            self.peerCheckRequest()
            d = maybeDeferred(self.coordinate)
            d.addCallback(self._startCallback3)
        else:
            self.queryloop = task.LoopingCall(self.query)
            self.queryloop.start(self.reservation_check_interval)

dataset/ETHPy150Open wehriam/awspider/awspider/servers/execution.py ExecutionServer._startCallback2/original