def audit_timeouts(self):
now = datetime.now()<EOL>for msg_id in self.depending.keys():<EOL><INDENT>if msg_id in self.depending:<EOL><INDENT>job = self.depending[msg_id]<EOL>if job.timeout and job.timeout < now:<EOL><INDENT>self.fail_unreachable(msg_id, error.TaskTimeout)<EOL><DEDENT><DEDENT><DEDENT>
Audit all waiting tasks for expired timeouts.