(self, value)
return False
Return True if item is in queue or currently being processed.
        False otherwise
Return True if item is in queue or currently being processed.
        False otherwise
Return True if item is in queue or currently being processed . False otherwise
def is_queued(self, value):
        """
        Return True if item is in queue or currently being processed.
        False otherwise
        """
        cli = raw_client()
        entries = self._q.structure_paths[1]
        # eek this is aweful
        try:
            items = {
                cli.get(join(entries, x))[0]
                for x in cli.get_children(entries)}
        except NoNodeError:
            items = []

        if util.tobytes(value) in items:
            return True
        return False
def is_queued ( self , value ) : cli = raw_client ( ) entries = self . _q . structure_paths [ 1 ] # eek this is aweful try : items = { cli . get ( join ( entries , x ) ) [ 0 ] for x in cli . get_children ( entries ) } except NoNodeError : items = [ ] if util . tobytes ( value ) in items : return True return False