Lines Matching refs:work_item
164 work_item = self.pending_work_items.pop(obj.work_id, None)
167 if work_item is not None:
168 work_item.future.set_exception(e)
269 work_item = pending_work_items[work_id]
271 if work_item.future.set_running_or_notify_cancel():
273 work_item.fn,
274 work_item.args,
275 work_item.kwargs),
385 for work_id, work_item in pending_work_items.items():
386 work_item.future.set_exception(bpe)
388 del work_item
406 work_item = pending_work_items.pop(result_item.work_id, None)
408 if work_item is not None:
410 work_item.future.set_exception(result_item.exception)
412 work_item.future.set_result(result_item.result)
414 del work_item