Module Import alias Import alias Import alias ImportFrom alias identifier Import alias ImportFrom alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Num Assign NameStore Call AttributeLoad NameLoad attr Str ListLoad Str Str Assign NameStore Call AttributeLoad NameLoad attr Str ListLoad Str Str Str Str ClassDef bases NameLoad body Expr Str Assign NameStore Dict Str Str Str Str Num Num Num Num Expr Str Assign NameStore Call NameLoad ListLoad Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword ListLoad Lambda arguments args NameParam NameParam defaults UnaryOpNot AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr If CompareIsNot NameLoad NameLoad body For NameStore Call NameLoad Call AttributeLoad NameLoad attr NameLoad body If CompareIn NameLoad NameLoad body Assign NameStore SubscriptLoad NameLoad Index NameLoad If CompareIn NameLoad AttributeLoad NameLoad attr body Assign NameStore Call NameLoad NameLoad orelse Assign NameStore Call NameLoad NameLoad If CompareLt NameLoad Num body Raise Call NameLoad BinOpMod Str TupleLoad NameLoad NameLoad Assign SubscriptStore NameLoad Index NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad If BoolOpAnd CompareEq NameLoad Str NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Str If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr If BoolOpAnd NameLoad CompareEq Call AttributeLoad NameLoad attr Str body Assign NameStore NameLoad If AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr orelse Assign NameStore Dict Assign NameStore Call NameLoad keyword NameLoad keyword AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword NameLoad Return Call NameLoad keyword Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore BinOpMod Str TupleLoad AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str If Call NameLoad NameLoad AttributeLoad NameLoad attr body Assign NameStore ListLoad NameLoad orelse Assign NameStore NameLoad Assign NameStore ListComp NameLoad comprehension NameStore NameLoad NameLoad If UnaryOpNot NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad AttributeLoad NameLoad attr Return FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword Call AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad NameLoad attr keyword ListLoad NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad With Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr attr keyword NameLoad NameStore body With Call AttributeLoad NameLoad attr NameStore body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad For NameStore NameLoad body Expr Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str FunctionDef arguments args NameParam NameParam defaults body TryExcept body Expr Call AttributeLoad NameLoad attr keyword NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr With Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr attr keyword NameLoad NameStore body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad Assign NameStore ListLoad AttributeLoad AttributeLoad NameLoad attr attr With Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad NameStore body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr TryFinally body While Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call NameLoad NameLoad AttributeLoad NameLoad attr If CompareIsNot AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr finalbody Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list
N/A N/A collections N/A threading N/A kombu kombu exceptions kombu_exceptions N/A six taskflow.engines.worker_based dispatcher taskflow logging N/A LOG N/A N/A logging getLogger __name__ N/A DRAIN_EVENTS_PERIOD 1 N/A _ConnectionDetails N/A N/A collections namedtuple _ConnectionDetails N/A uri transport N/A _TransportDetails N/A N/A collections namedtuple _TransportDetails N/A options driver_type driver_name driver_version Proxy N/A object N/A N/A A proxy processes messages from/to the named exchange.

    For **internal** usage only (not for public consumption).
     N/A DEFAULT_RETRY_OPTIONS N/A interval_start interval_step interval_max max_retries 1 1 1 3 N/A Settings used (by default) to reconnect under transient failures.

    See: http://kombu.readthedocs.org/ (and connection ``ensure_options``) for
    what these values imply/mean...
     N/A _RETRY_INT_OPTS N/A frozenset N/A max_retries __init__ N/A N/A self topic exchange type_handlers on_wait url transport transport_options retry_options N/A None None None None None None N/A N/A N/A self _topic topic N/A N/A self _exchange_name exchange N/A N/A self _on_wait on_wait N/A N/A self _running N/A N/A threading Event N/A N/A self _dispatcher N/A N/A dispatcher TypeDispatcher requeue_filters N/A N/A N/A N/A data message N/A N/A N/A self is_running type_handlers type_handlers N/A ensure_options N/A N/A N/A self DEFAULT_RETRY_OPTIONS copy N/A N/A retry_options None N/A N/A k N/A set N/A N/A six iterkeys ensure_options N/A N/A N/A k retry_options N/A N/A val N/A retry_options N/A k N/A N/A k N/A self _RETRY_INT_OPTS N/A N/A tmp_val N/A int val N/A N/A tmp_val N/A float val N/A N/A tmp_val 0 N/A N/A N/A ValueError N/A Expected value greater or equal to zero for 'retry_options' %s; got %s instead N/A k val N/A N/A ensure_options N/A k tmp_val N/A N/A self _ensure_options ensure_options N/A N/A self _drain_events_timeout DRAIN_EVENTS_PERIOD N/A N/A N/A transport memory transport_options N/A N/A polling_interval N/A N/A transport_options get polling_interval N/A N/A polling_interval None N/A N/A N/A self _drain_events_timeout polling_interval N/A N/A self _conn N/A N/A kombu Connection url transport transport transport_options transport_options N/A N/A self _exchange N/A N/A kombu Exchange name N/A self _exchange_name durable False auto_delete True N/A dispatcher N/A N/A self N/A N/A N/A Dispatcher internally used to dispatch message(s) that match. N/A N/A self _dispatcher N/A property connection_details N/A N/A self N/A N/A N/A Details about the connection (read-only). N/A driver_version N/A N/A N/A N/A self _conn transport driver_version N/A N/A driver_version N/A N/A N/A driver_version lower n/a N/A N/A driver_version None N/A N/A N/A self _conn transport_options N/A N/A transport_options N/A N/A N/A N/A self _conn transport_options copy N/A N/A transport_options N/A N/A transport N/A _TransportDetails options transport_options driver_type N/A N/A N/A self _conn transport driver_type driver_name N/A N/A N/A self _conn transport driver_name driver_version driver_version N/A N/A _ConnectionDetails uri N/A N/A N/A self _conn as_uri include_password False transport transport N/A property is_running N/A N/A self N/A N/A N/A Return whether the proxy is running. N/A N/A N/A N/A self _running is_set N/A property _make_queue N/A N/A self routing_key exchange channel N/A None N/A N/A Make a named queue for the given exchange. N/A queue_name N/A %s_%s N/A N/A self _exchange_name routing_key N/A N/A N/A kombu Queue name queue_name routing_key routing_key durable False exchange exchange auto_delete True channel channel N/A publish N/A N/A self msg routing_key reply_to correlation_id N/A None None N/A N/A Publish message to the named exchange with given routing key. N/A N/A isinstance routing_key N/A six string_types N/A N/A routing_keys N/A routing_key N/A N/A routing_keys routing_key N/A routing_keys N/A r_k N/A r_k routing_keys r_k N/A N/A routing_keys N/A N/A N/A N/A LOG warn No routing key/s specified; unable to send '%s' to any target queue on exchange '%s' msg N/A self _exchange_name N/A _publish N/A N/A producer routing_key N/A N/A N/A queue N/A N/A self _make_queue routing_key N/A self _exchange N/A N/A N/A producer publish body N/A N/A msg to_dict routing_key routing_key exchange N/A self _exchange declare N/A queue type N/A msg TYPE reply_to reply_to correlation_id correlation_id N/A _publish_errback N/A N/A exc interval N/A N/A N/A N/A N/A LOG exception Publishing error: %s exc N/A N/A N/A LOG info Retry triggering in %s seconds interval N/A N/A N/A N/A LOG debug Sending '%s' message using routing keys %s msg routing_keys N/A N/A N/A N/A N/A kombu connections N/A N/A self _conn acquire block True conn N/A N/A N/A N/A conn Producer producer N/A N/A ensure_kwargs N/A N/A N/A self _ensure_options copy N/A N/A ensure_kwargs N/A errback _publish_errback N/A safe_publish N/A N/A conn ensure producer _publish ensure_kwargs N/A routing_key routing_keys N/A N/A N/A safe_publish producer routing_key N/A start N/A N/A self N/A N/A N/A Start proxy. _drain N/A N/A conn timeout N/A N/A N/A N/A N/A N/A N/A conn drain_events timeout timeout N/A N/A N/A N/A kombu_exceptions TimeoutError N/A N/A N/A _drain_errback N/A N/A exc interval N/A N/A N/A N/A N/A LOG exception Draining error: %s exc N/A N/A N/A LOG info Retry triggering in %s seconds interval N/A N/A N/A N/A LOG info Starting to consume from the '%s' exchange. N/A self _exchange_name N/A N/A N/A N/A N/A kombu connections N/A N/A self _conn acquire block True conn N/A N/A queue N/A N/A self _make_queue N/A self _topic N/A self _exchange channel conn N/A callbacks N/A N/A N/A self _dispatcher on_message N/A N/A N/A conn Consumer queues queue callbacks callbacks consumer N/A N/A ensure_kwargs N/A N/A N/A self _ensure_options copy N/A N/A ensure_kwargs N/A errback _drain_errback N/A safe_drain N/A N/A conn ensure consumer _drain ensure_kwargs N/A N/A N/A N/A self _running set N/A N/A N/A N/A N/A N/A self _running is_set N/A N/A N/A safe_drain conn N/A self _drain_events_timeout N/A N/A N/A self _on_wait None N/A N/A N/A N/A self _on_wait N/A N/A N/A N/A N/A self _running clear N/A wait N/A N/A self N/A N/A N/A Wait until proxy is started. N/A N/A N/A N/A self _running wait N/A stop N/A N/A self N/A N/A N/A Stop proxy. N/A N/A N/A N/A self _running clear N/A N/A