Lines Matching refs:work_item
171 work_item = self.pending_work_items.pop(obj.work_id, None)
177 if work_item is not None:
178 work_item.future.set_exception(e)
354 work_item = self.pending_work_items[work_id]
356 if work_item.future.set_running_or_notify_cancel():
358 work_item.fn,
359 work_item.args,
360 work_item.kwargs),
412 work_item = self.pending_work_items.pop(result_item.work_id, None)
414 if work_item is not None:
416 work_item.future.set_exception(result_item.exception)
418 work_item.future.set_result(result_item.result)
454 for work_id, work_item in self.pending_work_items.items():
455 work_item.future.set_exception(bpe)
457 del work_item
479 for work_id, work_item in self.pending_work_items.items():
480 if not work_item.future.cancel():
481 new_pending_work_items[work_id] = work_item