Searched refs:_delay_ready_task (Results 1 – 2 of 2) sorted by relevance
849 self.assert_(not job._delay_ready_task)859 self.assert_(job._delay_ready_task)894 job._delay_ready_task.end_time = time.time() - 111111902 job._delay_ready_task.end_time = time.time() + 111111939 self.assertEqual(job._delay_ready_task, delay_task)940 self.assert_(job._delay_ready_task)941 self.assertFalse(job._delay_ready_task.is_done())942 self.assertFalse(job._delay_ready_task.aborted)952 self.assertTrue(job._delay_ready_task.aborted)953 self.assertFalse(job._delay_ready_task.success)[all …]
944 _delay_ready_task = None variable in Job1482 delay_expired = (self._delay_ready_task and1483 time.time() >= self._delay_ready_task.end_time)1500 if self._delay_ready_task:1518 self._delay_ready_task = DelayedCallTask(delay_seconds=delay,1520 return self._delay_ready_task1544 if self._delay_ready_task:1547 self._delay_ready_task.abort()