environment/lib/python2.7/site-packages/IPython/parallel/controller/scheduler.py
def audit_timeouts(self):
        """Audit all waiting tasks for expired timeouts."""
        now = datetime.now()
        for msg_id in self.depending.keys():
            # must recheck, in case one failure cascaded to another:
            if msg_id in self.depending:
                job = self.depending[msg_id]
                if job.timeout and job.timeout < now:
                    self.fail_unreachable(msg_id, error.TaskTimeout)
def audit_timeouts(self):
        now = datetime.now()
        for msg_id in self.depending.keys():
            # must recheck, in case one failure cascaded to another:
            if msg_id in self.depending:
                job = self.depending[msg_id]
                if job.timeout and job.timeout < now:
                    self.fail_unreachable(msg_id, error.TaskTimeout)
def audit_timeouts ( self ) : now = datetime . now ( ) for msg_id in self . depending . keys ( ) : # must recheck, in case one failure cascaded to another: if msg_id in self . depending : job = self . depending [ msg_id ] if job . timeout and job . timeout < now : self . fail_unreachable ( msg_id , error . TaskTimeout )
Audit all waiting tasks for expired timeouts.
Audit all waiting tasks for expired timeouts .