Module ImportFrom alias alias Import alias Import alias Import alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias alias alias alias ImportFrom alias ImportFrom alias alias alias alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults ListLoad ListLoad NameLoad NameLoad NameLoad Num Num Num Num Num Num Num Num NameLoad kwarg body If BoolOpAnd UnaryOpNot NameLoad UnaryOpNot NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr ListComp Call NameLoad NameLoad comprehension NameStore NameLoad Assign AttributeStore NameLoad attr Call NameLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad If NameLoad body Assign AttributeStore NameLoad attr NameLoad orelse Assign AttributeStore NameLoad attr BinOpMod Str TupleLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad If CompareLt NameLoad Num body Assign AttributeStore NameLoad attr Call NameLoad orelse Assign AttributeStore NameLoad attr NameLoad If NameLoad body Assign AttributeStore NameLoad attr Call NameLoad orelse Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr Dict decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body If Call NameLoad NameLoad AttributeLoad NameLoad attr body Return Call NameLoad ListLoad NameLoad orelse If Call NameLoad NameLoad TupleLoad NameLoad NameLoad NameLoad body Return Call NameLoad NameLoad Raise Call NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam defaults body If Call NameLoad NameLoad AttributeLoad NameLoad attr body Return ListLoad NameLoad orelse If Call NameLoad NameLoad TupleLoad NameLoad NameLoad body Assign NameStore Call NameLoad NameLoad Return NameLoad Assign NameStore Str Raise Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str If CompareNotEq AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr Return If UnaryOpNot Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr body Raise Call NameLoad Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr For NameStore Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Return Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str Call NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str Call NameLoad AttributeLoad NameLoad attr For NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return CompareIn AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call NameLoad GeneratorExp AttributeLoad NameLoad attr comprehension NameStore AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad Num BinOpFloorDiv AttributeLoad NameLoad attr Call NameLoad Num Call NameLoad AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad GeneratorExp AttributeLoad NameLoad attr comprehension NameStore AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad GeneratorExp AttributeLoad NameLoad attr comprehension NameStore AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return BinOpAdd AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body If CompareEq AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return If CompareEq AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return If BoolOpAnd CompareEq AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr body Assign NameStore Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod NameLoad TupleLoad NameLoad AttributeLoad NameLoad attr Return If UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return Assign NameStore BinOpAdd BinOpSub AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad If CompareGt NameLoad AttributeLoad NameLoad attr body If UnaryOpNot BoolOpOr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Expr Call AttributeLoad NameLoad attr Num AttributeLoad NameLoad attr NameLoad NameLoad Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad TryExcept body Expr Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str For NameStore AttributeLoad NameLoad attr body Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr Str Assign NameStore Call NameLoad NameLoad Call NameLoad NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign NameStore Call NameLoad AttributeLoad NameLoad attr TryExcept body Assign NameStore SubscriptLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Index Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str Call NameLoad NameLoad handlers ExceptHandler type NameLoad name NameStore body Assign NameStore Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod NameLoad TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Return For NameStore NameLoad body Assign NameStore Call NameLoad BoolOpOr Call AttributeLoad NameLoad attr Str SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad For NameStore AttributeLoad NameLoad attr body TryExcept body Expr Call AttributeLoad NameLoad attr Num handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr If UnaryOpNot NameLoad body Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Num decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign NameStore AttributeLoad NameLoad attr For NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore BinOpMult AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr BinOpMult Call AttributeLoad NameLoad attr NameLoad While NameLoad body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body While NameLoad body Expr Call AttributeLoad NameLoad attr Num If UnaryOpNot AttributeLoad NameLoad attr body Continue Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If CompareEq AttributeLoad NameLoad attr NameLoad body Return NameLoad If AttributeLoad NameLoad attr body Return NameLoad If CompareGt Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Return NameLoad If BoolOpAnd CompareEq AttributeLoad NameLoad attr NameLoad CompareGt Call NameLoad AttributeLoad NameLoad attr Num body Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad For NameStore AttributeLoad NameLoad attr body If CompareEq AttributeLoad NameLoad attr Num body Continue If CompareLt BinOpSub Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Continue Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad TryExcept body Expr Call AttributeLoad NameLoad attr Num handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad If CompareEq AttributeLoad NameLoad attr NameLoad body Assign NameStore BinOpSub Num AttributeLoad NameLoad attr orelse Assign NameStore BinOpSub AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareLtE NameLoad Num body Return Assign NameStore Call NameLoad AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad Call NameLoad NameLoad Call NameLoad AttributeLoad NameLoad attr For NameStore NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Num decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareLtE Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Return NameLoad If CompareLt BinOpSub Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num body Return NameLoad Assign NameStore ListComp NameLoad comprehension NameStore AttributeLoad NameLoad attr UnaryOpNot AttributeLoad NameLoad attr If UnaryOpNot NameLoad body Return NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareIn AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad body Return Assign NameStore Call AttributeLoad NameLoad attr NameLoad If CompareGtE AttributeLoad NameLoad attr Call NameLoad BinOpMult AttributeLoad NameLoad attr Num Num body Return Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return NameLoad Return Call AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr If CompareIs NameLoad NameLoad body Raise Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return If CompareIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return If CompareIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad TryFinally body TryExcept body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr If CompareLt AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad Str attr ListLoad Str Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod NameLoad TupleLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Num handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return finalbody Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body For TupleStore NameStore NameStore AttributeLoad NameLoad attr body If UnaryOpNot AttributeLoad NameLoad attr body Continue Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad If CompareNotIn Call NameLoad NameLoad AttributeLoad NameLoad attr body Return Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr If CompareEq AttributeLoad NameLoad attr NameLoad body Return If AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad If CompareNotIn Call NameLoad NameLoad AttributeLoad NameLoad attr body Return Assign NameStore Call AttributeLoad Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If BoolOpAnd AttributeLoad NameLoad attr CompareGt AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign NameStore Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod NameLoad TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Return Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad If UnaryOpNot AttributeLoad NameLoad attr body Return If AttributeLoad NameLoad attr body Return If Call AttributeLoad NameLoad attr body Return Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad TryExcept body Return Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad name NameStore body If CompareIs AttributeLoad NameLoad attr NameLoad body Assign NameStore AttributeLoad NameLoad attr orelse Assign NameStore AttributeLoad NameLoad attr ExceptHandler type NameLoad name NameStore body Assign NameStore NameLoad Assign NameStore BinOpMod Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad If UnaryOpNot AttributeLoad NameLoad attr body Return If Call AttributeLoad NameLoad attr body Return TryExcept body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad name NameStore body Assign NameStore BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Assign NameStore Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod NameLoad TupleLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore ListLoad If Call AttributeLoad NameLoad attr Str body Expr Call AttributeLoad NameLoad attr BinOpMod Str SubscriptLoad NameLoad Index Str If Call AttributeLoad NameLoad attr Str body Expr Call AttributeLoad NameLoad attr BinOpMod Str SubscriptLoad NameLoad Index Str If Call AttributeLoad NameLoad attr Str body Expr Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str TupleLoad NameLoad Call AttributeLoad Str attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return If CompareIn AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad body Return If NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr If BoolOpAnd CompareEq AttributeLoad NameLoad attr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr body Return Call AttributeLoad NameLoad attr If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body Return Call AttributeLoad NameLoad attr decorator_list decorator_list
N/A __future__ absolute_import division N/A logging N/A random N/A gevent N/A blinker N/A time N/A six itertools cycle collections defaultdict multiprocessing cpu_count gevent.queue Queue six.moves range lookupd Lookupd nsqd Nsqd backofftimer BackoffTimer states INIT RUNNING BACKOFF THROTTLED CLOSED decorators cached_property errors NSQException NSQNoConnections NSQRequeueMessage NSQSocketError Reader N/A object N/A N/A High level NSQ consumer.

    A Reader will connect to the nsqd tcp addresses or poll the provided
    nsqlookupd http addresses for the configured topic and send signals to
    message handlers connected to the `on_message` signal or provided by
    `message_handler`.

    Messages will automatically be finished when the message handle returns
    unless the readers `async` flag is set to `True`. If an exception occurs or
    :class:`gnsq.errors.NSQRequeueMessage` is raised, the message will be
    requeued.

    The Reader will handle backing off of failed messages up to a configurable
    `max_interval` as well as automatically reconnecting to dropped connections.

    :param topic: specifies the desired NSQ topic

    :param channel: specifies the desired NSQ channel

    :param nsqd_tcp_addresses: a sequence of string addresses of the nsqd
        instances this reader should connect to

    :param lookupd_http_addresses: a sequence of string addresses of the
        nsqlookupd instances this reader should query for producers of the
        specified topic

    :param name: a string that is used for logging messages (defaults to
        'gnsq.reader.topic.channel')

    :param message_handler: the callable that will be executed for each message
        received

    :param async: consider the message handling to be async. The message will
        not automatically be finished after the handler returns and must
        manually be called

    :param max_tries: the maximum number of attempts the reader will make to
        process a message after which messages will be automatically discarded

    :param max_in_flight: the maximum number of messages this reader will
        pipeline for processing. this value will be divided evenly amongst the
        configured/discovered nsqd producers

    :param max_concurrency: the maximum number of messages that will be handled
        concurrently. Defaults to the number of nsqd connections. Setting
        `max_concurrency` to `-1` will use the systems cpu count.

    :param requeue_delay: the default delay to use when requeueing a failed
        message

    :param lookupd_poll_interval: the amount of time in seconds between querying
        all of the supplied nsqlookupd instances.  A random amount of time based
        on this value will be initially introduced in order to add jitter when
        multiple readers are running

    :param lookupd_poll_jitter: the maximum fractional amount of jitter to add
        to the lookupd pool loop. This helps evenly distribute requests even if
        multiple consumers restart at the same time.

    :param low_ready_idle_timeout: the amount of time in seconds to wait for a
        message from a producer when in a state where RDY counts are
        re-distributed (ie. max_in_flight < num_producers)

    :param max_backoff_duration: the maximum time we will allow a backoff state
        to last in seconds. If zero, backoff wil not occur

    :param backoff_on_requeue: if False, backoff will only occur on exception

    :param \*\*kwargs: passed to :class:`gnsq.Nsqd` initialization
     __init__ N/A N/A self topic channel nsqd_tcp_addresses lookupd_http_addresses name message_handler async max_tries max_in_flight max_concurrency requeue_delay lookupd_poll_interval lookupd_poll_jitter low_ready_idle_timeout max_backoff_duration backoff_on_requeue N/A N/A N/A None None False 5 1 0 0 60 0.3 10 128 True kwargs N/A N/A N/A N/A nsqd_tcp_addresses N/A lookupd_http_addresses N/A N/A N/A ValueError must specify at least on nsqd or lookupd N/A nsqd_tcp_addresses N/A N/A self _get_nsqds nsqd_tcp_addresses N/A lookupd_http_addresses N/A N/A self _get_lookupds lookupd_http_addresses N/A N/A N/A random shuffle lookupd_http_addresses N/A N/A self nsqd_tcp_addresses nsqd_tcp_addresses N/A N/A self lookupds N/A N/A Lookupd a N/A a lookupd_http_addresses N/A N/A self iterlookupds N/A cycle N/A self lookupds N/A N/A self topic topic N/A N/A self channel channel N/A N/A self async async N/A N/A self max_tries max_tries N/A N/A self max_in_flight max_in_flight N/A N/A self requeue_delay requeue_delay N/A N/A self lookupd_poll_interval lookupd_poll_interval N/A N/A self lookupd_poll_jitter lookupd_poll_jitter N/A N/A self low_ready_idle_timeout low_ready_idle_timeout N/A N/A self backoff_on_requeue backoff_on_requeue N/A N/A self max_backoff_duration max_backoff_duration N/A N/A self conn_kwargs kwargs N/A name N/A N/A N/A self name name N/A N/A N/A self name N/A %s.%s.%s N/A __name__ N/A self topic N/A self channel N/A N/A message_handler None N/A N/A N/A N/A N/A self on_message connect message_handler weak False N/A N/A max_concurrency 0 N/A N/A N/A self max_concurrency N/A cpu_count N/A N/A N/A self max_concurrency max_concurrency N/A max_concurrency N/A N/A N/A self queue N/A Queue N/A N/A N/A self queue None N/A N/A self _need_ready_redistributed False N/A N/A self last_random_ready N/A N/A time time N/A N/A self state INIT N/A N/A self logger N/A N/A logging getLogger N/A self name N/A N/A self conn_backoffs N/A defaultdict N/A self create_backoff N/A N/A self backoff N/A N/A self create_backoff N/A N/A self conns N/A set N/A N/A self pending N/A set N/A N/A self workers N/A N/A N/A self conn_workers N/A N/A on_message N/A N/A self N/A N/A N/A Emitted when a message is received.

        The signal sender is the reader and the `message` is sent as an
        argument. The `message_handler` param is connected to this signal.
         N/A N/A N/A blinker Signal doc Emitted when a message is received. N/A cached_property on_response N/A N/A self N/A N/A N/A Emitted when a response is received.

        The signal sender is the reader and the `response` is sent as an
        argument.
         N/A N/A N/A blinker Signal doc Emitted when a response is received. N/A cached_property on_error N/A N/A self N/A N/A N/A Emitted when an error is received.

        The signal sender is the reader and the `error` is sent as an
        argument.
         N/A N/A N/A blinker Signal doc Emitted when a error is received. N/A cached_property on_finish N/A N/A self N/A N/A N/A Emitted after a message is successfully finished.

        The signal sender is the reader and the `message_id` is sent as an
        argument.
         N/A N/A N/A blinker Signal doc Emitted after the a message is finished. N/A cached_property on_requeue N/A N/A self N/A N/A N/A Emitted after a message is requeued.

        The signal sender is the reader and the `message_id` and `timeout`
        are sent as arguments.
         N/A N/A N/A blinker Signal doc Emitted after the a message is requeued. N/A cached_property on_giving_up N/A N/A self N/A N/A N/A Emitted after a giving up on a message.

        Emitted when a message has exceeded the maximum number of attempts
        (`max_tries`) and will no longer be requeued. This is useful to perform
        tasks such as writing to disk, collecting statistics etc. The signal
        sender is the reader and the `message` is sent as an argument.
         N/A N/A N/A blinker Signal doc Sent after a giving up on a message. N/A cached_property on_auth N/A N/A self N/A N/A N/A Emitted after a connection is successfully authenticated.

        The signal sender is the reader and the `conn` and parsed `response` are
        sent as arguments.
         N/A N/A N/A blinker Signal doc Emitted when a response is received. N/A cached_property on_exception N/A N/A self N/A N/A N/A Emitted when an exception is caught while handling a message.

        The signal sender is the reader and the `message` and `error` are sent
        as arguments.
         N/A N/A N/A blinker Signal doc Emitted when an exception is caught. N/A cached_property on_close N/A N/A self N/A N/A N/A Emitted after :meth:`close`.

        The signal sender is the reader.
         N/A N/A N/A blinker Signal doc Emitted after the reader is closed. N/A cached_property _get_nsqds N/A N/A self nsqd_tcp_addresses N/A N/A N/A N/A isinstance nsqd_tcp_addresses N/A six string_types N/A N/A N/A set N/A nsqd_tcp_addresses N/A N/A N/A isinstance nsqd_tcp_addresses N/A list tuple set N/A N/A N/A set nsqd_tcp_addresses N/A N/A TypeError nsqd_tcp_addresses must be a list, set or tuple N/A _get_lookupds N/A N/A self lookupd_http_addresses N/A N/A N/A N/A isinstance lookupd_http_addresses N/A six string_types N/A N/A N/A lookupd_http_addresses N/A N/A N/A isinstance lookupd_http_addresses N/A list tuple N/A N/A lookupd_http_addresses N/A list lookupd_http_addresses N/A lookupd_http_addresses N/A msg lookupd_http_addresses must be a list, set or tuple N/A N/A TypeError msg N/A start N/A N/A self block N/A True N/A N/A Start discovering and listing to connections. N/A N/A N/A self state INIT N/A N/A N/A N/A N/A self logger warn N/A %s all ready started N/A self name N/A block N/A N/A N/A N/A self join N/A N/A N/A N/A any N/A N/A N/A self on_message receivers_for N/A blinker ANY N/A N/A N/A RuntimeError no receivers connected to on_message N/A N/A N/A N/A self logger debug N/A starting %s... N/A self name N/A N/A self state RUNNING N/A N/A N/A self query_nsqd N/A N/A self lookupds N/A N/A N/A N/A self query_lookupd N/A N/A N/A N/A self workers append N/A N/A gevent spawn N/A self _poll_lookupd N/A N/A N/A N/A self workers append N/A N/A gevent spawn N/A self _poll_ready N/A _ N/A range N/A self max_concurrency N/A N/A N/A N/A N/A self workers append N/A N/A gevent spawn N/A self _run N/A block N/A N/A N/A N/A self join N/A close N/A N/A self N/A N/A N/A Immediately close all connections and stop workers. N/A N/A N/A self is_running N/A N/A N/A N/A self state CLOSED N/A N/A N/A N/A self logger debug N/A closing %d worker(s) N/A len N/A self workers N/A N/A N/A gevent killall N/A self workers block False N/A N/A N/A N/A self logger debug N/A closing %d connection(s) N/A len N/A self conns N/A conn N/A self conns N/A N/A N/A N/A conn close_stream N/A N/A N/A N/A self on_close send self N/A join N/A N/A self timeout raise_error N/A None False N/A N/A Block until all connections have closed and workers stopped. N/A N/A N/A gevent joinall N/A self workers timeout raise_error N/A N/A N/A gevent joinall N/A list N/A N/A N/A self conn_workers values timeout raise_error N/A is_running N/A N/A self N/A N/A N/A Check if reader is currently running. N/A N/A N/A self state N/A RUNNING BACKOFF THROTTLED N/A property is_starved N/A N/A self N/A N/A N/A Evaluate whether any of the connections are starved.

        This property should be used by message handlers to reliably identify
        when to process a batch of messages.
         N/A N/A any N/A N/A conn is_starved N/A conn N/A self conns N/A property connection_max_in_flight N/A N/A self N/A N/A N/A N/A max 1 N/A N/A self max_in_flight N/A max 1 N/A len N/A self conns N/A property total_ready_count N/A N/A self N/A N/A N/A N/A sum N/A N/A c ready_count N/A c N/A self conns N/A property total_in_flight N/A N/A self N/A N/A N/A N/A sum N/A N/A c in_flight N/A c N/A self conns N/A property total_in_flight_or_ready N/A N/A self N/A N/A N/A N/A N/A self total_in_flight N/A self total_ready_count N/A property send_ready N/A N/A self conn count N/A N/A N/A N/A N/A self state CLOSED N/A N/A N/A N/A N/A self logger debug N/A [%s] cannot send RDY (in state CLOSED) conn N/A N/A N/A N/A self state BACKOFF N/A N/A N/A N/A N/A self logger debug N/A [%s] cannot send RDY (in state BACKOFF) conn N/A N/A N/A N/A N/A self state THROTTLED N/A self total_in_flight_or_ready N/A N/A msg [%s] cannot send RDY (THROTTLED and %d in flight or ready) N/A N/A N/A N/A self logger debug N/A msg N/A conn N/A self total_in_flight_or_ready N/A N/A N/A N/A conn is_connected N/A N/A N/A N/A N/A self logger debug N/A [%s] cannot send RDY (connection closed) conn N/A N/A total N/A N/A N/A self total_ready_count N/A conn ready_count count N/A N/A total N/A self max_in_flight N/A N/A N/A N/A N/A conn ready_count N/A conn in_flight N/A N/A N/A N/A N/A self logger debug N/A [%s] sending later conn N/A N/A N/A gevent spawn_later 5 N/A self send_ready conn count N/A N/A N/A N/A N/A self logger debug N/A [%s] sending RDY %d N/A conn count N/A N/A N/A N/A N/A conn ready count N/A N/A N/A NSQSocketError N/A error N/A N/A N/A N/A N/A self logger warn N/A [%s] RDY %d failed (%r) N/A conn count error N/A query_nsqd N/A N/A self N/A N/A N/A N/A N/A N/A self logger debug querying nsqd... N/A address N/A self nsqd_tcp_addresses N/A N/A N/A address port N/A N/A address split : N/A conn N/A Nsqd address N/A int port N/A self conn_kwargs N/A N/A N/A self connect_to_nsqd conn N/A query_lookupd N/A N/A self N/A N/A N/A N/A N/A N/A self logger debug querying lookupd... N/A lookupd N/A next N/A self iterlookupds N/A N/A N/A producers N/A N/A N/A lookupd lookup N/A self topic N/A producers N/A N/A N/A N/A self logger debug N/A found %d producers N/A len producers N/A N/A N/A Exception N/A error N/A N/A msg Failed to lookup %s on %s (%s) N/A N/A N/A N/A self logger warn N/A msg N/A N/A self topic N/A lookupd address error N/A N/A producer producers N/A N/A conn N/A Nsqd N/A N/A N/A producer get broadcast_address N/A producer N/A address N/A producer N/A tcp_port N/A producer N/A http_port N/A self conn_kwargs N/A N/A N/A self connect_to_nsqd conn N/A create_backoff N/A N/A self N/A N/A N/A N/A BackoffTimer max_interval N/A self max_backoff_duration N/A start_backoff N/A N/A self N/A N/A N/A N/A self state BACKOFF N/A conn N/A self conns N/A N/A N/A N/A N/A N/A conn ready 0 N/A N/A N/A NSQSocketError N/A error N/A N/A N/A N/A N/A self logger warn N/A [%s] RDY 0 failed (%r) N/A conn error N/A interval N/A N/A N/A self backoff get_interval N/A N/A N/A N/A self logger info N/A backing off for %s seconds interval N/A N/A N/A gevent sleep interval N/A N/A self state THROTTLED N/A conn N/A N/A self random_connection N/A N/A conn N/A N/A N/A N/A N/A N/A self logger info N/A [%s] testing backoff state with RDY 1 conn N/A N/A N/A self send_ready conn 1 N/A complete_backoff N/A N/A self N/A N/A N/A N/A self state RUNNING N/A N/A N/A N/A self logger info backoff complete, resuming normal operation N/A count N/A self connection_max_in_flight N/A conn N/A self conns N/A N/A N/A N/A self send_ready conn count N/A _poll_lookupd N/A N/A self N/A N/A N/A delay N/A N/A self lookupd_poll_interval N/A self lookupd_poll_jitter N/A N/A N/A gevent sleep N/A N/A N/A random random delay N/A True N/A N/A N/A N/A gevent sleep N/A self lookupd_poll_interval N/A N/A N/A self query_lookupd N/A _poll_ready N/A N/A self N/A N/A N/A True N/A N/A N/A N/A gevent sleep 5 N/A N/A N/A self need_ready_redistributed N/A N/A N/A N/A N/A self redistribute_ready_state N/A need_ready_redistributed N/A N/A self N/A N/A N/A N/A N/A self state BACKOFF N/A N/A False N/A N/A self _need_ready_redistributed N/A N/A True N/A N/A N/A len N/A self conns N/A self max_in_flight N/A N/A True N/A N/A N/A N/A self state THROTTLED N/A N/A len N/A self conns 1 N/A N/A True N/A property need_ready_redistributed N/A N/A self value N/A N/A N/A N/A self _need_ready_redistributed value N/A N/A need_ready_redistributed setter redistribute_ready_state N/A N/A self N/A N/A N/A N/A self need_ready_redistributed False N/A conn N/A self conns N/A N/A N/A N/A conn ready_count 0 N/A N/A N/A N/A N/A N/A N/A time time N/A conn last_message N/A self low_ready_idle_timeout N/A N/A N/A N/A N/A N/A self logger info N/A [%s] idle connection, giving up RDY count conn N/A N/A N/A N/A N/A conn ready 0 N/A N/A N/A NSQSocketError N/A error N/A N/A N/A N/A N/A self logger warn N/A [%s] RDY 0 failed (%r) N/A conn error N/A N/A N/A self state THROTTLED N/A N/A max_in_flight N/A 1 N/A self total_in_flight_or_ready N/A N/A max_in_flight N/A N/A self max_in_flight N/A self total_ready_count N/A N/A max_in_flight 0 N/A N/A N/A conns N/A list N/A self conns N/A conns N/A N/A random sample conns N/A min max_in_flight N/A len N/A self conns N/A conn conns N/A N/A N/A N/A N/A self logger info N/A [%s] redistributing RDY conn N/A N/A N/A self send_ready conn 1 N/A random_ready_conn N/A N/A self conn N/A N/A N/A N/A N/A len N/A self conns N/A self max_in_flight N/A N/A conn N/A N/A N/A N/A N/A time time N/A self last_random_ready 30 N/A N/A conn N/A ready_conns N/A c N/A c N/A self conns N/A N/A c ready_count N/A N/A ready_conns N/A N/A conn N/A N/A self last_random_ready N/A N/A time time N/A N/A N/A random choice ready_conns N/A update_ready N/A N/A self conn N/A N/A N/A N/A N/A self state N/A BACKOFF THROTTLED N/A N/A N/A conn N/A N/A self random_ready_conn conn N/A N/A N/A conn ready_count N/A max N/A N/A conn last_ready 0.25 2 N/A N/A N/A N/A N/A self send_ready conn N/A self connection_max_in_flight N/A random_connection N/A N/A self N/A N/A N/A N/A N/A self conns N/A N/A None N/A N/A N/A random choice N/A list N/A self conns N/A publish N/A N/A self topic message N/A N/A N/A Publish a message to a random connection. N/A conn N/A N/A self random_connection N/A N/A conn None N/A N/A N/A NSQNoConnections N/A N/A N/A conn publish topic message N/A connect_to_nsqd N/A N/A self conn N/A N/A N/A N/A N/A self is_running N/A N/A N/A N/A conn N/A self conns N/A N/A N/A N/A N/A self logger debug N/A [%s] already connected conn N/A N/A N/A conn N/A self pending N/A N/A N/A N/A N/A self logger debug N/A [%s] already pending conn N/A N/A N/A N/A N/A self logger debug N/A [%s] connecting... conn N/A N/A N/A N/A conn on_response connect N/A self handle_response N/A N/A N/A N/A conn on_error connect N/A self handle_error N/A N/A N/A N/A conn on_finish connect N/A self handle_finish N/A N/A N/A N/A conn on_requeue connect N/A self handle_requeue N/A N/A N/A N/A conn on_auth connect N/A self handle_auth N/A N/A self max_concurrency N/A N/A N/A N/A N/A conn on_message connect N/A self queue_message N/A N/A N/A N/A N/A conn on_message connect N/A self handle_message N/A N/A N/A N/A self pending add conn N/A N/A N/A N/A N/A N/A N/A conn connect N/A N/A N/A conn identify N/A N/A N/A conn max_ready_count N/A self max_in_flight N/A N/A msg N/A N/A join N/A [%s] max RDY count %d < reader max in flight %d, truncation possible N/A N/A N/A N/A self logger warning N/A msg N/A conn N/A conn max_ready_count N/A self max_in_flight N/A N/A N/A conn subscribe N/A self topic N/A self channel N/A N/A N/A self send_ready conn 1 N/A N/A N/A NSQException N/A error N/A N/A N/A N/A N/A self logger warn N/A [%s] connection failed (%r) N/A conn error N/A N/A N/A self handle_connection_failure conn N/A N/A N/A N/A N/A N/A self pending remove conn N/A N/A N/A self is_running N/A N/A N/A N/A conn close_stream N/A N/A N/A N/A N/A self logger info N/A [%s] connection successful conn N/A N/A N/A self handle_connection_success conn N/A _listen N/A N/A self conn N/A N/A N/A N/A N/A N/A N/A conn listen N/A N/A N/A NSQException N/A error N/A N/A N/A N/A N/A self logger warning N/A [%s] connection lost (%r) N/A conn error N/A N/A N/A self handle_connection_failure conn N/A _run N/A N/A self N/A N/A N/A N/A conn message N/A self queue N/A N/A N/A N/A conn is_connected N/A N/A N/A N/A N/A self handle_message conn message N/A queue_message N/A N/A self conn message N/A N/A N/A N/A N/A N/A self logger debug N/A [%s] queueing message: %s N/A conn N/A message id N/A N/A N/A N/A self queue put N/A conn message N/A handle_connection_success N/A N/A self conn N/A N/A N/A N/A N/A N/A self conns add conn N/A N/A N/A self conn_workers N/A conn N/A N/A gevent spawn N/A self _listen conn N/A N/A N/A str conn N/A self nsqd_tcp_addresses N/A N/A N/A N/A N/A N/A N/A self conn_backoffs N/A conn success N/A handle_connection_failure N/A N/A self conn N/A N/A N/A N/A N/A N/A self conns discard conn N/A N/A N/A N/A self conn_workers pop conn None N/A N/A N/A conn close_stream N/A N/A N/A self state CLOSED N/A N/A N/A N/A conn ready_count N/A N/A N/A self need_ready_redistributed True N/A N/A N/A str conn N/A self nsqd_tcp_addresses N/A N/A N/A seconds N/A N/A N/A N/A N/A N/A self conn_backoffs N/A conn failure get_interval N/A N/A N/A N/A self logger debug N/A [%s] retrying in %ss N/A conn seconds N/A N/A N/A gevent spawn_later seconds N/A self connect_to_nsqd conn N/A handle_response N/A N/A self conn response N/A N/A N/A N/A N/A N/A self logger debug N/A [%s] response: %s N/A conn response N/A N/A N/A N/A self on_response send self response response N/A handle_error N/A N/A self conn error N/A N/A N/A N/A N/A N/A self logger debug N/A [%s] error: %s N/A conn error N/A N/A N/A N/A self on_error send self error error N/A _handle_message N/A N/A self message N/A N/A N/A N/A N/A self max_tries N/A N/A message attempts N/A self max_tries N/A N/A msg giving up on message '%s' after max tries %d N/A N/A N/A N/A self logger warning N/A msg N/A N/A message id N/A self max_tries N/A N/A N/A N/A self on_giving_up send self message message N/A N/A N/A message finish N/A N/A N/A N/A self on_message send self message message N/A N/A N/A self is_running N/A N/A N/A N/A self async N/A N/A N/A N/A N/A message has_responded N/A N/A N/A N/A N/A message finish N/A handle_message N/A N/A self conn message N/A N/A N/A N/A N/A N/A self logger debug N/A [%s] got message: %s N/A conn N/A message id N/A N/A N/A self update_ready conn N/A N/A N/A N/A N/A self _handle_message message N/A N/A N/A NSQRequeueMessage N/A error N/A N/A N/A N/A error backoff None N/A N/A backoff N/A self backoff_on_requeue N/A N/A backoff N/A error backoff N/A N/A Exception N/A error N/A N/A backoff True N/A msg N/A [%s] caught exception while handling message conn N/A N/A N/A N/A self logger exception msg N/A N/A N/A N/A self on_exception send self message message error error N/A N/A N/A self is_running N/A N/A N/A N/A N/A message has_responded N/A N/A N/A N/A N/A N/A N/A message requeue N/A self requeue_delay backoff N/A N/A N/A NSQException N/A error N/A N/A msg N/A [%s] error requeueing message (%r) N/A conn error N/A N/A N/A N/A self logger warning msg N/A handle_finish N/A N/A self conn message_id N/A N/A N/A N/A N/A N/A self logger debug N/A [%s] finished message: %s N/A conn message_id N/A N/A N/A self handle_backoff False N/A N/A N/A self update_ready conn N/A N/A N/A N/A self on_finish send self message_id message_id N/A handle_requeue N/A N/A self conn message_id timeout backoff N/A N/A N/A msg [%s] requeued message: %s (%s) N/A N/A N/A N/A self logger debug N/A msg N/A conn message_id timeout N/A N/A N/A self handle_backoff backoff N/A N/A N/A self update_ready conn N/A N/A N/A N/A self on_requeue send self message_id message_id timeout timeout N/A handle_auth N/A N/A self conn response N/A N/A N/A metadata N/A N/A N/A N/A response get identity N/A N/A N/A N/A metadata append N/A Identity: %r N/A response N/A identity N/A N/A N/A response get permission_count N/A N/A N/A N/A metadata append N/A Permissions: %d N/A response N/A permission_count N/A N/A N/A response get identity_url N/A N/A N/A N/A metadata append N/A response N/A identity_url N/A N/A N/A N/A self logger info N/A [%s] AUTH accepted %s N/A conn N/A N/A join metadata N/A N/A N/A N/A self on_auth send self conn conn response response N/A handle_backoff N/A N/A self backoff N/A N/A N/A N/A N/A self max_backoff_duration N/A N/A N/A N/A N/A self state N/A BACKOFF CLOSED N/A N/A N/A backoff N/A N/A N/A N/A N/A self backoff failure N/A N/A N/A N/A N/A self backoff success N/A N/A N/A N/A self state THROTTLED N/A N/A N/A self backoff is_reset N/A N/A N/A N/A self complete_backoff N/A N/A N/A N/A N/A self backoff is_reset N/A N/A N/A N/A self start_backoff N/A N/A