parameters: (self, e)
docstring: Validates that the given exception represents worker preemption.
docstring_summary: Validates that the given exception represents worker preemption.
docstring_tokens: Validates that the given exception represents worker preemption .
function: def _validate_preemption_failure(self, e):
      """Validates that the given exception represents worker preemption."""
  
      # Only categorize the failure as a worker preemption if the cancellation
      # manager did not attempt to cancel the blocking operations.
      if _is_worker_failure(e) and (
          not self._cluster.closure_queue._cancellation_mgr.is_cancelled):  # pylint: disable=protected-access
        return
      raise e
function_tokens: def _validate_preemption_failure ( self , e ) : # Only categorize the failure as a worker preemption if the cancellation # manager did not attempt to cancel the blocking operations. if _is_worker_failure ( e ) and ( not self . _cluster . closure_queue . _cancellation_mgr . is_cancelled ) : # pylint: disable=protected-access return raise e