Module Expr Str Import alias ImportFrom alias ImportFrom alias TryExcept body ImportFrom alias handlers ExceptHandler type NameLoad body ImportFrom alias identifier Import alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults Num body Expr Str Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str FunctionDef arguments args defaults vararg kwarg body Assign NameStore Num While CompareLtE NameLoad AttributeLoad NameLoad attr body TryExcept body Return Call NameLoad NameLoad NameLoad handlers ExceptHandler body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str If CompareEq NameLoad AttributeLoad NameLoad attr body Raise AugAssignAdd NameStore Num decorator_list Call NameLoad NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str If CompareIs NameLoad NameLoad body Assign NameStore ListLoad Str Assign AttributeStore NameLoad attr Dict For NameStore NameLoad body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad For TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr Str Assign NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad TryExcept body Assign NameStore Call AttributeLoad NameLoad attr Str Assign TupleStore NameStore NameStore TupleLoad SubscriptLoad NameLoad Index Num SubscriptLoad NameLoad Index Num Assign NameStore SubscriptLoad NameLoad Slice Num Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call NameLoad NameLoad NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Index NameLoad handlers ExceptHandler type AttributeLoad AttributeLoad NameLoad attr attr body Pass If UnaryOpNot AttributeLoad NameLoad attr body Raise Call NameLoad Str Expr Call AttributeLoad NameLoad attr BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults vararg kwarg body Expr Str TryExcept body Return Call AttributeLoad Call AttributeLoad NameLoad attr attr NameLoad NameLoad handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str Raise decorator_list Call NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore BinOpMult ListLoad Call NameLoad NameLoad NameLoad Return Call NameLoad keyword NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults Num NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore ListLoad Str NameLoad NameLoad NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad body Expr Str Assert NameLoad Assign NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str AugAssignAdd NameStore BinOpAdd ListLoad Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad If UnaryOpNot NameLoad body Return ListLoad If NameLoad body Return ListComp TupleLoad NameLoad NameLoad NameLoad NameLoad NameLoad comprehension TupleStore NameStore NameStore NameStore NameStore NameStore NameStore NameStore NameLoad orelse Return ListComp TupleLoad NameLoad NameLoad NameLoad comprehension TupleStore NameStore NameStore NameStore NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad If NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num Assign NameStore Call NameLoad GeneratorExp TupleLoad NameLoad NameLoad comprehension TupleStore NameStore NameStore NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Str NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Return Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Return Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Return Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad If NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num Assign NameStore Call NameLoad GeneratorExp TupleLoad NameLoad NameLoad comprehension TupleStore NameStore NameStore NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults Num NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults Num NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If CompareIs Call NameLoad NameLoad NameLoad body For NameStore NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad If NameLoad body AugAssignAdd NameStore ListLoad Str NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Str decorator_list decorator_list If CompareEq NameLoad Str body Expr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign NameStore Call NameLoad ListLoad Str Str Expr Call AttributeLoad NameLoad attr Import alias Assign NameStore Call AttributeLoad NameLoad attr ListLoad Str Str Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr ListLoad Str keyword Num For TupleStore NameStore NameStore NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad
N/A N/A Pydisque makes Disque easy to access in python. N/A redis redis.exceptions ConnectionError functools wraps N/A N/A itertools zip_longest N/A N/A N/A ImportError N/A itertools izip_longest zip_longest N/A logging N/A logger N/A N/A logging getLogger __name__ Job N/A object N/A N/A Represents a Disque Job. __init__ N/A N/A self id queue_name payload N/A N/A N/A Initialize a job. N/A N/A self id id N/A N/A self queue_name queue_name N/A N/A self payload payload N/A __repr__ N/A N/A self N/A N/A N/A Make a Job easy to read. N/A N/A <Job id:%s queue_name:%s> N/A N/A self id N/A self queue_name N/A N/A Node N/A object N/A N/A Represents a Disque Node via host and port. __init__ N/A N/A self node_id host port connection N/A N/A N/A 
        Initialize a the Disque Node.

        :param node_id:
        :param host:
        :param port:
        :param connection: redis.Redis connection
        :returns:
         N/A N/A self node_id node_id N/A N/A self host host N/A N/A self port port N/A N/A self connection connection N/A __repr__ N/A N/A self N/A N/A N/A Make Node easy to read. N/A N/A <Node %s:%s> N/A N/A self host N/A self port N/A N/A retry N/A object N/A N/A retry utility object. __init__ N/A N/A self retry_count N/A 2 N/A N/A Initialize retry utility object. N/A N/A self retry_count retry_count N/A __call__ N/A N/A self fn N/A N/A N/A Function wrapper. wrapped_f N/A N/A N/A args kwargs N/A N/A c 0 N/A N/A c N/A self retry_count N/A N/A N/A N/A N/A fn args kwargs N/A N/A N/A N/A N/A N/A logging critical retrying because of this exception - %s c N/A N/A N/A logging exception exception to retry  N/A N/A c N/A self retry_count N/A N/A N/A c 1 N/A N/A wraps fn N/A wrapped_f N/A N/A Client N/A object N/A N/A 
    Client is the Disque Client.

    You can pass in a list of nodes, it will try to connect to
    first if it can't then it will try to connect to second and
    so forth.

    :Example:

    >>> client = Client(['localhost:7711', 'localhost:7712'])
    >>> client.connect()

     __init__ N/A N/A self nodes N/A None N/A N/A Initalize a client to the specified nodes. N/A N/A nodes None N/A N/A nodes N/A localhost:7711 N/A N/A self nodes N/A N/A n nodes N/A N/A N/A N/A self nodes N/A n None N/A N/A self connected_node None N/A connect N/A N/A self N/A N/A N/A 
        Connect to one of the Disque nodes.

        You can get current connection with connected_node property

        :returns: nothing
         N/A N/A self connected_node None N/A N/A i node N/A N/A N/A self nodes items N/A N/A N/A host port N/A N/A i split : N/A port N/A int port N/A redis_client N/A N/A redis Redis host port N/A N/A N/A ret N/A N/A redis_client execute_command HELLO N/A N/A format_version node_id N/A N/A ret N/A 0 N/A ret N/A 1 N/A others N/A ret N/A 2 N/A N/A N/A self nodes N/A i N/A Node node_id host port redis_client N/A N/A self connected_node N/A N/A self nodes N/A i N/A N/A N/A N/A N/A redis exceptions ConnectionError N/A N/A N/A N/A N/A self connected_node N/A N/A N/A Exception couldnt connect to any nodes N/A N/A N/A logger info N/A connected to node %s N/A self connected_node N/A get_connection N/A N/A self N/A N/A N/A 
        Return current connected_nodes connection.

        :rtype: redis.Redis
         N/A N/A N/A self connected_node connection N/A execute_command N/A N/A self N/A args kwargs N/A N/A Execute a command on the connected server. N/A N/A N/A N/A N/A N/A N/A self get_connection execute_command args kwargs N/A N/A N/A ConnectionError N/A e N/A N/A N/A N/A logger warn trying to reconnect N/A N/A N/A self connect N/A N/A N/A logger warn connected N/A N/A N/A retry _grouper N/A N/A self iterable n fillvalue N/A None N/A N/A Collect data into fixed-length chunks or blocks. N/A args N/A N/A N/A iter iterable n N/A N/A zip_longest fillvalue fillvalue args N/A info N/A N/A self N/A N/A N/A 
        Return server information.

        INFO

        :returns: server info
         N/A N/A N/A self execute_command INFO N/A add_job N/A N/A self queue_name job timeout replicate delay retry ttl maxlen async N/A 200 None None None None None None N/A N/A 
        Add a job to a queue.

        ADDJOB queue_name job <ms-timeout> [REPLICATE <count>] [DELAY <sec>]
            [RETRY <sec>] [TTL <sec>] [MAXLEN <count>] [ASYNC]

        :param queue_name: is the name of the queue, any string, basically.
        :param job: is a string representing the job.
        :param timeout: is the command timeout in milliseconds.
        :param replicate: count is the number of nodes the job should be
            replicated to.
        :param delay: sec is the number of seconds that should elapse
            before the job is queued by any server.
        :param retry: sec period after which, if no ACK is received, the
            job is put again into the queue for delivery. If RETRY is 0,
            the job has an at-least-once delivery semantics.
        :param ttl: sec is the max job life in seconds. After this time,
            the job is deleted even if it was not successfully delivered.
        :param maxlen: count specifies that if there are already count
            messages queued for the specified queue name, the message is
            refused and an error reported to the client.
        :param async: asks the server to let the command return ASAP and
            replicate the job to other nodes in the background. The job
            gets queued ASAP, while normally the job is put into the queue
            only when the client gets a positive reply.

        :returns: job_id
         N/A command N/A ADDJOB queue_name job timeout N/A replicate N/A N/A command N/A REPLICATE replicate N/A delay N/A N/A command N/A DELAY delay N/A retry N/A N/A command N/A RETRY retry N/A ttl N/A N/A command N/A TTL ttl N/A maxlen N/A N/A command N/A MAXLEN maxlen N/A async N/A N/A command N/A ASYNC N/A N/A N/A logger debug sending job - %s command N/A job_id N/A N/A self execute_command command N/A N/A N/A logger debug sent job - %s command N/A N/A N/A logger debug N/A job_id: %s  job_id N/A job_id N/A get_job N/A N/A self queues timeout count nohang withcounters N/A None None False False N/A N/A 
        Return some number of jobs from specified queues.

        GETJOB [NOHANG] [TIMEOUT <ms-timeout>] [COUNT <count>] [WITHCOUNTERS] FROM
            queue1 queue2 ... queueN

        :param queues: name of queues

        :returns: list of tuple(job_id, queue_name, job), tuple(job_id, queue_name, job, nacks, additional_deliveries) or empty list
        :rtype: list
         N/A queues N/A command N/A GETJOB N/A nohang N/A N/A command N/A NOHANG N/A timeout N/A N/A command N/A TIMEOUT timeout N/A count N/A N/A command N/A COUNT count N/A withcounters N/A N/A command N/A WITHCOUNTERS N/A command N/A N/A FROM queues N/A results N/A N/A self execute_command command N/A N/A results N/A N/A N/A N/A withcounters N/A N/A N/A N/A job_id queue_name job nacks additional_deliveries N/A N/A job_id queue_name job _ nacks _ additional_deliveries results N/A N/A N/A N/A job_id queue_name job N/A N/A job_id queue_name job results N/A ack_job N/A N/A self N/A job_ids N/A N/A 
        Acknowledge the execution of one or more jobs via job IDs.

        ACKJOB jobid1 jobid2 ... jobidN

        :param job_ids: list of job_ids

         N/A N/A N/A self execute_command ACKJOB job_ids N/A nack_job N/A N/A self N/A job_ids N/A N/A 
        Acknowledge the failure of one or more jobs via job IDs.

        NACK jobid1 jobid2 ... jobidN

        :param job_ids: list of job_ids

         N/A N/A N/A self execute_command NACK job_ids N/A fast_ack N/A N/A self N/A job_ids N/A N/A 
        Perform a best effort cluster wide deletion of the specified job IDs.

        FASTACK jobid1 jobid2 ... jobidN

        :param job_ids:

         N/A N/A N/A self execute_command FASTACK job_ids N/A working N/A N/A self job_id N/A N/A N/A 
        Signal Disque to postpone the next time it will deliver the job again.

        WORKING <jobid>

        :param job_id: name of the job still being worked on
        :returns: returns the number of seconds you (likely)
            postponed the message visiblity for other workers
         N/A N/A N/A self execute_command WORKING job_id N/A qlen N/A N/A self queue_name N/A N/A N/A 
        Return the length of the named queue.

        QLEN <qname>

        :param queue_name: name of the queue
        :returns: length of the queue

         N/A N/A N/A self execute_command QLEN queue_name N/A qstat N/A N/A self queue_name return_dict N/A False N/A N/A 
        Return the status of the queue (currently unimplemented).

        Future support / testing of QSTAT support in Disque

        QSTAT <qname>

        Return produced ... consumed ... idle ... sources [...] ctime ...
         N/A rtn N/A N/A self execute_command QSTAT queue_name N/A return_dict N/A N/A grouped N/A N/A self _grouper rtn 2 N/A rtn N/A dict N/A N/A a b N/A N/A a b grouped N/A rtn N/A qpeek N/A N/A self queue_name count N/A N/A N/A 
        Return, without consuming from queue, count jobs.

        If count is positive the specified number of jobs are
        returned from the oldest to the newest (in the same
        best-effort FIFO order as GETJOB). If count is negative
        the commands changes behavior and shows the count newest jobs,
        from the newest from the oldest.

        QPEEK <qname> <count>

        :param queue_name: name of the queue
        :param count:

         N/A N/A N/A self execute_command QPEEK queue_name count N/A enqueue N/A N/A self N/A job_ids N/A N/A 
        Queue jobs if not already queued.

        :param job_ids:

         N/A N/A N/A self execute_command ENQUEUE job_ids N/A dequeue N/A N/A self N/A job_ids N/A N/A 
        Remove the job from the queue.

        :param job_ids: list of job_ids

         N/A N/A N/A self execute_command DEQUEUE job_ids N/A del_job N/A N/A self N/A job_ids N/A N/A 
        Completely delete a job from a node.

        Note that this is similar to FASTACK, but limited to a
        single node since no DELJOB cluster bus message is sent
        to other nodes.

        :param job_ids:

         N/A N/A N/A self execute_command DELJOB job_ids N/A show N/A N/A self job_id return_dict N/A False N/A N/A 
        Describe the job.

        :param job_id:

         N/A rtn N/A N/A self execute_command SHOW job_id N/A return_dict N/A N/A grouped N/A N/A self _grouper rtn 2 N/A rtn N/A dict N/A N/A a b N/A N/A a b grouped N/A rtn N/A pause N/A N/A self queue_name kw_in kw_out kw_all kw_none kw_state kw_bcast N/A None None None None None None N/A N/A 
        Pause a queue.

        Unfortunately, the PAUSE keywords are mostly reserved words in Python,
        so I've been a little creative in the function variable names. Open
        to suggestions to change it (canardleteer)

        :param queue_name: The job queue we are modifying.
        :param kw_in: pause the queue in input.
        :param kw_out: pause the queue in output.
        :param kw_all: pause the queue in input and output (same as specifying
                       both the in and out options).
        :param kw_none: clear the paused state in input and output.
        :param kw_state: just report the current queue state.
        :param kw_bcast: send a PAUSE command to all the reachable nodes of
                         the cluster to set the same queue in the other nodes
                         to the same state.
         N/A command N/A PAUSE queue_name N/A kw_in N/A N/A command N/A in N/A kw_out N/A N/A command N/A out N/A kw_all N/A N/A command N/A all N/A kw_none N/A N/A command N/A none N/A kw_state N/A N/A command N/A state N/A kw_bcast N/A N/A command N/A bcast N/A N/A N/A self execute_command command N/A qscan N/A N/A self cursor count busyloop minlen maxlen importrate N/A 0 None None None None None N/A N/A 
        Iterate all the existing queues in the local node.

        :param count: An hint about how much work to do per iteration.
        :param busyloop: Block and return all the elements in a busy loop.
        :param minlen: Don't return elements with less than count jobs queued.
        :param maxlen: Don't return elements with more than count jobs queued.
        :param importrate: Only return elements with an job import rate
                        (from other nodes) >= rate.
         N/A command N/A QSCAN cursor N/A count N/A N/A command N/A COUNT count N/A busyloop N/A N/A command N/A BUSYLOOP N/A minlen N/A N/A command N/A MINLEN minlen N/A maxlen N/A N/A command N/A MAXLEN maxlen N/A importrate N/A N/A command N/A IMPORTRATE importrate N/A N/A N/A self execute_command command N/A jscan N/A N/A self cursor count busyloop queue state reply N/A 0 None None None None None N/A N/A Iterate all the existing jobs in the local node.

        :param count: An hint about how much work to do per iteration.
        :param busyloop: Block and return all the elements in a busy loop.
        :param queue: Return only jobs in the specified queue.
        :param state: Must be a list - Return jobs in the specified state.
            Can be used multiple times for a logic OR.
        :param reply: None or string {"all", "id"} - Job reply type. Type can
            be all or id. Default is to report just the job ID. If all is
            specified the full job state is returned like for the SHOW command.
         N/A command N/A JSCAN cursor N/A count N/A N/A command N/A COUNT count N/A busyloop N/A N/A command N/A BUSYLOOP N/A queue N/A N/A command N/A QUEUE queue N/A N/A N/A type state list N/A N/A s state N/A N/A command N/A STATE s N/A reply N/A N/A command N/A REPLY reply N/A N/A N/A self execute_command command N/A hello N/A N/A self N/A N/A N/A 
        Returns hello format version, this node ID, all the nodes IDs, IP addresses, ports, and priority (lower is better, means node more available).
        Clients should use this as an handshake command when connecting with a Disque node.

        HELLO
        :returns: [<hello format version>, <this node ID>, [<all the nodes IDs, IP addresses, ports, and priority>, ...]
         N/A N/A N/A self execute_command HELLO N/A N/A N/A N/A __name__ __main__ N/A N/A N/A N/A logging basicConfig level N/A logging DEBUG N/A c N/A Client N/A localhost:7712 localhost:7711 N/A N/A N/A c connect N/A json N/A job N/A N/A json dumps N/A hello 1234 N/A N/A N/A logger info N/A N/A c add_job test job N/A jobs N/A N/A c get_job N/A test timeout 5 N/A N/A queue_name job_id payload jobs N/A N/A N/A N/A logger info job_id N/A N/A N/A c ack_job job_id