def deregister(self, identity):
        try:
            target = self._targets.pop(identity)
        except __HOLE__:
            pass
        else:
            # Just incase set the barrier to unblock any worker...
            target.barrier.set()
            if LOG.isEnabledFor(logging.TRACE):
                LOG.trace("Dispatched %s messages %s to target '%s' during"
                          " the lifetime of its existence in the dispatcher",
                          sum(six.itervalues(target.dispatched)),
                          dict(target.dispatched), target)
dataset/ETHPy150Open openstack/taskflow/taskflow/engines/action_engine/executor.py/_Dispatcher.deregister