Pulp

Thread 6 (Thread 0x7f09f2ffd700 (LWP 11569)):

Thread 5 (Thread 0x7f09f3fff700 (LWP 11567)):

Thread 4 (Thread 0x7f0a20eaf880 (LWP 11131)):

#4 Waiting for a lock (e.g. GIL)

#5 Frame 0x55730f53e150, for file /usr/lib64/python2.7/sre_parse.py, line 396, in _parse (source=<Tokenizer(index=13, string='sys.exc_clear', next='r') at remote 0x557311050170>, state=<Pattern(groupdict={}, open=[], flags=2, str='sys.exc_clear', groups=1) at remote 0x5573107f1a28>, subpattern=<SubPattern(pattern=<...>, data=[('literal', 115), ('literal', 121), ('literal', 115), ('any', None), ('literal', 101), ('literal', 120), ('literal', 99), ('literal', 95), ('literal', 99), ('literal', 108), ('literal', 101), ('literal', 97)], width=None) at remote 0x5573107f1e18>, subpatternappend=<instancemethod at remote 0x5573116e8820>, sourceget=<instancemethod at remote 0x5573117c7230>, sourcematch=<instancemethod at remote 0x55731028be60>, _len=<built-in function len>, PATTERNENDERS=set([')', '|']), ASSERTCHARS=set(['!', '=', '<']), LOOKBEHINDASSERTCHARS=set(['!', '=']), REPEATCODES=set(['min_repeat', 'max_repeat']), this='a')

if source.next in PATTERNENDERS:

#8 Frame 0x55730f53ab90, for file /usr/lib64/python2.7/sre_parse.py, line 309, in _parse_sub (source=<Tokenizer(index=13, string='sys.exc_clear', next='r') at remote 0x557311050170>, state=<Pattern(groupdict={}, open=[], flags=2, str='sys.exc_clear', groups=1) at remote 0x5573107f1a28>, nested=0, items=[], itemsappend=<built-in method append of list object at remote 0x7f09d80dbf80>, sourcematch=<instancemethod at remote 0x55730f912eb0>)

itemsappend(_parse(source, state))

#12 Frame 0x55730f546a50, for file /usr/lib64/python2.7/sre_parse.py, line 686, in parse (str='sys.exc_clear', flags=2, pattern=<Pattern(groupdict={}, open=[], flags=2, str='sys.exc_clear', groups=1) at remote 0x5573107f1a28>, source=<Tokenizer(index=13, string='sys.exc_clear', next='r') at remote 0x557311050170>)

p = _parse_sub(source, pattern, 0)

#16 Frame 0x55730f53be10, for file /usr/lib64/python2.7/sre_compile.py, line 499, in compile (p='sys.exc_clear', flags=2, pattern='sys.exc_clear')

p = sre_parse.parse(p, flags)

#20 Frame 0x557310370810, for file /usr/lib64/python2.7/re.py, line 240, in _compile (key=('sys.exc_clear', 2), cachekey=(<type at remote 0x7f0a15faab00>, 'sys.exc_clear', 2), p=None, pattern='sys.exc_clear', flags=2)

p = sre_compile.compile(pattern, flags)

#24 Frame 0x5573105aea30, for file /usr/lib64/python2.7/re.py, line 190, in compile (pattern='sys.exc_clear', flags=2)

return _compile(pattern, flags)

#28 Frame 0x5573105a6750, for file /usr/lib64/python2.7/warnings.py, line 67, in filterwarnings (action='ignore', message='sys.exc_clear', category=<type at remote 0x7f0a15f98e20>, module='threading', lineno=0, append=0, re=<module at remote 0x7f0a20d5aef8>)

item = (action, re.compile(message, re.I), category,

#32 Frame 0x55731127ead0, for file /usr/lib64/python2.7/threading.py, line 44, in <module> ()

module='threading', message='sys.exc_clear')

Thread 3 (Thread 0x7f09e6ff5700 (LWP 13421)):

Thread 2 (Thread 0x7f09f37fe700 (LWP 11568)):

Thread 1 (Thread 0x7f09f8f90700 (LWP 11566)):

#2 Frame 0x7f09f40267b0, for file /usr/lib/python2.7/site-packages/django/dispatch/dispatcher.py, line 282, in _remove_receiver ()

self.sender_receivers_cache.clear()

#6 Frame 0x557311e47a10, for file /usr/lib/python2.7/site-packages/qpid/compat.py, line 127, in wait (self=<PipeWaiter(write_fd=33, read_fd=32) at remote 0x557311dfc2d8>, timeout=3, start=<float at remote 0x5573103b1458>, ready=False)

ready, _, _ = select([self], [], [], timeout)

#10 Frame 0x557311e32500, for file /usr/lib/python2.7/site-packages/qpid/concurrency.py, line 96, in wait (self=<Condition(lock=<_RLock(_Verbose__verbose=False, _RLock__owner=None, _RLock__block=<thread.lock at remote 0x55731187eb30>, _RLock__count=0) at remote 0x557311de6ad0>, waiting=[<PipeWaiter(write_fd=33, read_fd=32) at remote 0x557311dfc2d8>], waiters=[]) at remote 0x557311d60248>, timeout=3, sw=<...>, st=(2, 139680808503040))

sw.wait(timeout)

#14 Frame 0x557311e31f80, for file /usr/lib/python2.7/site-packages/qpid/concurrency.py, line 59, in wait (self=<Waiter(condition=<Condition(lock=<_RLock(_Verbose__verbose=False, _RLock__owner=None, _RLock__block=<thread.lock at remote 0x55731187eb30>, _RLock__count=0) at remote 0x557311de6ad0>, waiting=[<PipeWaiter(write_fd=33, read_fd=32) at remote 0x557311dfc2d8>], waiters=[]) at remote 0x557311d60248>) at remote 0x557311de6b10>, predicate=<function at remote 0x557311df9cf8>, timeout=3, passed=0, start=<float at remote 0x5573103b1398>)

self.condition.wait(timeout - passed)

#18 Frame 0x557311e31da0, for file /usr/lib/python2.7/site-packages/qpid/messaging/endpoints.py, line 252, in _wait (self=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _status='OPEN', _op_enc=<OpEncoder(segments=[]) at remote 0x557311dfcbd8>, _sasl=<WrapperClient(_cli=<Client(this=<SwigPyObject at remote 0x557311de9f90>) at remote 0x557311de69d0>) at remote 0x557311dfcf80>, _op_dec=<OpDecoder(current_op={}, ops=[]) at remote 0x557311dfc7e8>, _connected=True, _frame_dec=<FrameDecoder(track=0, parse=<instance...(truncated)

return self._waiter.wait(predicate, timeout=timeout)

#22 Frame 0x557311e31bb0, for file /usr/lib/python2.7/site-packages/qpid/messaging/endpoints.py, line 273, in _ewait (self=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _status='OPEN', _op_enc=<OpEncoder(segments=[]) at remote 0x557311dfcbd8>, _sasl=<WrapperClient(_cli=<Client(this=<SwigPyObject at remote 0x557311de9f90>) at remote 0x557311de69d0>) at remote 0x557311dfcf80>, _op_dec=<OpDecoder(current_op={}, ops=[]) at remote 0x557311dfc7e8>, _connected=True, _frame_dec=<FrameDecoder(track=0, parse=<instanc...(truncated)

result = self._wait(lambda: self.error or predicate(), timeout)

#26 Frame 0x557311e3a600, for file /usr/lib/python2.7/site-packages/qpid/messaging/endpoints.py, line 637, in _ewait (self=<Session(_async_exception_notify_handler=None, _pop=<function at remote 0x7f09d80d5b18>, sync=<function at remote 0x7f09d80d5b18>, check_error=<function at remote 0x7f09d80d5b18>, set_message_received_notify_handler=<function at remote 0x7f09d80d5b18>, committed=True, close=<function at remote 0x7f09d80d5b18>, __setattr__=<function at remote 0x7f09d80d5b18>, senders=[], __init__=<function at remote 0x7f09d80d5b18>, receiver=<function at remote 0x7f09d80d5b18>, next_receiver=<function at remote 0x7f09d80d5b18>, aborting=False, set_message_received_handler=<function at remote 0x7f09d80d5b18>, _ewait=<function at remote 0x7f09d80d5b18>, _peek=<function at remote 0x7f09d80d5b18>, transactional=False, _lock=<_RLock(_Verbose__verbose=False, _RLock__owner=None, _RLock__block=<thread.lock at remote 0x55731187eb30>, _RLock__count=0) at remote 0x557311de6ad0>, _wait=<function at remote 0x7f09d80d5b18>,...(truncated)

result = self.connection._ewait(lambda: self.error or predicate(), timeout)

#30 Frame 0x557311e57060, for file /usr/lib/python2.7/site-packages/qpid/messaging/endpoints.py, line 730, in _get (self=<Session(_async_exception_notify_handler=None, _pop=<function at remote 0x7f09d80d5b18>, sync=<function at remote 0x7f09d80d5b18>, check_error=<function at remote 0x7f09d80d5b18>, set_message_received_notify_handler=<function at remote 0x7f09d80d5b18>, committed=True, close=<function at remote 0x7f09d80d5b18>, __setattr__=<function at remote 0x7f09d80d5b18>, senders=[], __init__=<function at remote 0x7f09d80d5b18>, receiver=<function at remote 0x7f09d80d5b18>, next_receiver=<function at remote 0x7f09d80d5b18>, aborting=False, set_message_received_handler=<function at remote 0x7f09d80d5b18>, _ewait=<function at remote 0x7f09d80d5b18>, _peek=<function at remote 0x7f09d80d5b18>, transactional=False, _lock=<_RLock(_Verbose__verbose=False, _RLock__owner=None, _RLock__block=<thread.lock at remote 0x55731187eb30>, _RLock__count=0) at remote 0x557311de6ad0>, _wait=<function at remote 0x7f09d80d5b18>, c...(truncated)

timeout):

#34 Frame 0x557311e56790, for file <string>, line 6, in _get (self=<Session(_async_exception_notify_handler=None, _pop=<function at remote 0x7f09d80d5b18>, sync=<function at remote 0x7f09d80d5b18>, check_error=<function at remote 0x7f09d80d5b18>, set_message_received_notify_handler=<function at remote 0x7f09d80d5b18>, committed=True, close=<function at remote 0x7f09d80d5b18>, __setattr__=<function at remote 0x7f09d80d5b18>, senders=[], __init__=<function at remote 0x7f09d80d5b18>, receiver=<function at remote 0x7f09d80d5b18>, next_receiver=<function at remote 0x7f09d80d5b18>, aborting=False, set_message_received_handler=<function at remote 0x7f09d80d5b18>, _ewait=<function at remote 0x7f09d80d5b18>, _peek=<function at remote 0x7f09d80d5b18>, transactional=False, _lock=<_RLock(_Verbose__verbose=False, _RLock__owner=None, _RLock__block=<thread.lock at remote 0x55731187eb30>, _RLock__count=0) at remote 0x557311de6ad0>, _wait=<function at remote 0x7f09d80d5b18>, closed=False, ack_capacity=<Constant(name='UNLIMITED', ...(truncated)

(in an eval block)

#38 Frame 0x557311e52920, for file /usr/lib/python2.7/site-packages/qpid/messaging/endpoints.py, line 1152, in fetch (self=<Receiver(_get_capacity=<function at remote 0x7f09d80d5aa0>, _capacity=0, _async_exception_notify_handler=None, check_error=<function at remote 0x7f09d80d5aa0>, draining=False, session=<Session(_async_exception_notify_handler=None, _pop=<function at remote 0x7f09d80d5b18>, sync=<function at remote 0x7f09d80d5b18>, check_error=<function at remote 0x7f09d80d5b18>, set_message_received_notify_handler=<function at remote 0x7f09d80d5b18>, committed=True, close=<function at remote 0x7f09d80d5b18>, __setattr__=<function at remote 0x7f09d80d5b18>, senders=[], __init__=<function at remote 0x7f09d80d5b18>, receiver=<function at remote 0x7f09d80d5b18>, next_receiver=<function at remote 0x7f09d80d5b18>, aborting=False, set_message_received_handler=<function at remote 0x7f09d80d5b18>, _ewait=<function at remote 0x7f09d80d5b18>, _peek=<function at remote 0x7f09d80d5b18>, transactional=False, _lock=<_RLock(...(truncated)

msg = self.session._get(self, timeout=timeout)

#42 Frame 0x557311e56c80, for file <string>, line 6, in fetch (self=<Receiver(_get_capacity=<function at remote 0x7f09d80d5aa0>, _capacity=0, _async_exception_notify_handler=None, check_error=<function at remote 0x7f09d80d5aa0>, draining=False, session=<Session(_async_exception_notify_handler=None, _pop=<function at remote 0x7f09d80d5b18>, sync=<function at remote 0x7f09d80d5b18>, check_error=<function at remote 0x7f09d80d5b18>, set_message_received_notify_handler=<function at remote 0x7f09d80d5b18>, committed=True, close=<function at remote 0x7f09d80d5b18>, __setattr__=<function at remote 0x7f09d80d5b18>, senders=[], __init__=<function at remote 0x7f09d80d5b18>, receiver=<function at remote 0x7f09d80d5b18>, next_receiver=<function at remote 0x7f09d80d5b18>, aborting=False, set_message_received_handler=<function at remote 0x7f09d80d5b18>, _ewait=<function at remote 0x7f09d80d5b18>, _peek=<function at remote 0x7f09d80d5b18>, transactional=False, _lock=<_RLock(_Verbose__verbose=False, _RLock__owner=None, _RLock__bl...(truncated)

(in an eval block)

#46 Frame 0x7f09ec021d20, for file /usr/lib/python2.7/site-packages/gofer/messaging/adapter/qpid/consumer.py, line 116, in get (self=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _status='OPEN', _op_enc=<OpEncoder(segments=[]) at remote 0x557311dfcbd...(truncated)

impl = self.receiver.fetch(timeout or NO_DELAY)

#51 Frame 0x557311dc25d0, for file /usr/lib/python2.7/site-packages/gofer/messaging/adapter/qpid/reliability.py, line 36, in _fn (thing=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float a

t remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _status='OPEN', _op_enc=<OpEncoder(segments=[]) at remote 0x557311df...(truncated)

return fn(thing, *args, **kwargs)

#55 Frame 0x7f09ec0221a0, for file /usr/lib/python2.7/site-packages/gofer/messaging/adapter/model.py, line 620, in get (self=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _statu...(truncated)

return self._impl.get(timeout)

#60 Frame 0x557311c10240, for file /usr/lib/python2.7/site-packages/gofer/messaging/adapter/model.py, line 39, in _fn (args=(<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _statu...(truncated)

return fn(*args, **keywords)

#64 Frame 0x55730f7a9d20, for file /usr/lib/python2.7/site-packages/gofer/messaging/adapter/model.py, line 654, in next (self=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _stat...(truncated)

message = self.get(timeout)

#69 Frame 0x557311e4bd70, for file /usr/lib/python2.7/site-packages/gofer/messaging/adapter/model.py, line 39, in _fn (args=(<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_hostname_check_actual=True, client_properties={}, _driver=<Driver(_next_retry=None, engine=<Engine(address_cache=<Cache(entries={'pulp.task': (<float at remote 0x5573103b1380>, ('queue', None))}, ttl=60) at remote 0x557311dfc560>, _channels=0, _hdr='AMQP\x01\x01\x00\n', _out=<LinkOut() at remote 0x557311dfc518>, _seg_enc=<SegmentEncoder(frames=[], max_payload=65523) at remote 0x557311dfcef0>, channel_max=65534, _last_in=<float at remote 0x55731101e8d0>, _channel_max=65536, _statu...(truncated)

return fn(*args, **keywords)

#73 Frame 0x7f09f400e950, for file /usr/lib/python2.7/site-packages/gofer/messaging/consumer.py, line 93, in read (self=<ReplyConsumer(node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, listener=<ReplyHandler(consumer=<...>) at remote 0x557311bd4d88>, _Thread__ident=139680808503040, _Thread__block=<_Condition(_Verbose__verbose=False, _Condition__lock=<thread.lock at remote 0x55731187e810>, acquire=<built-in method acquire of thread.lock object at remote 0x55731187e810>, _Condition__waiters=[], release=<built-in method release of thread.lock object at remote 0x55731187e810>) at remote 0x557311de6850>, _Thread__name='pulp.task', _Thread__daemonic=True, reader=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protoco...(truncated)

message, document = reader.next(wait)

#76 Frame 0x7f09ec000d60, for file /usr/lib/python2.7/site-packages/gofer/messaging/consumer.py, line 61, in run (self=<ReplyConsumer(node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, listener=<ReplyHandler(consumer=<...>) at remote 0x557311bd4d88>, _Thread__ident=139680808503040, _Thread__block=<_Condition(_Verbose__verbose=False, _Condition__lock=<thread.lock at remote 0x55731187e810>, acquire=<built-in method acquire of thread.lock object at remote 0x55731187e810>, _Condition__waiters=[], release=<built-in method release of thread.lock object at remote 0x55731187e810>) at remote 0x557311de6850>, _Thread__name='pulp.task', _Thread__daemonic=True, reader=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol...(truncated)

self.read()

#81 Frame 0x7f09ec000b50, for file /usr/lib/python2.7/site-packages/gofer/common.py, line 273, in _fn (args=(<ReplyConsumer(node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, listener=<ReplyHandler(consumer=<...>) at remote 0x557311bd4d88>, _Thread__ident=139680808503040, _Thread__block=<_Condition(_Verbose__verbose=False, _Condition__lock=<thread.lock at remote 0x55731187e810>, acquire=<built-in method acquire of thread.lock object at remote 0x55731187e810>, _Condition__waiters=[], release=<built-in method release of thread.lock object at remote 0x55731187e810>) at remote 0x557311de6850>, _Thread__name='pulp.task', _Thread__daemonic=True, reader=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ss...(truncated)

return fn(*args, **kwargs)

#85 Frame 0x7f09ec000910, for file /usr/lib64/python2.7/threading.py, line 812, in __bootstrap_inner (self=<ReplyConsumer(node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, listener=<ReplyHandler(consumer=<...>) at remote 0x557311bd4d88>, _Thread__ident=139680808503040, _Thread__block=<_Condition(_Verbose__verbose=False, _Condition__lock=<thread.lock at remote 0x55731187e810>, acquire=<built-in method acquire of thread.lock object at remote 0x55731187e810>, _Condition__waiters=[], release=<built-in method release of thread.lock object at remote 0x55731187e810>) at remote 0x557311de6850>, _Thread__name='pulp.task', _Thread__daemonic=True, reader=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_...(truncated)

self.run()

---Type <return> to continue, or q <return> to quit---

#88 Frame 0x55730f70c2f0, for file /usr/lib64/python2.7/threading.py, line 785, in __bootstrap (self=<ReplyConsumer(node=<Queue(exclusive=False, name='pulp.task', url=None, durable=True, expiration=0, auto_delete=False) at remote 0x557311bb25d0>, listener=<ReplyHandler(consumer=<...>) at remote 0x557311bd4d88>, _Thread__ident=139680808503040, _Thread__block=<_Condition(_Verbose__verbose=False, _Condition__lock=<thread.lock at remote 0x55731187e810>, acquire=<built-in method acquire of thread.lock object at remote 0x55731187e810>, _Condition__waiters=[], release=<built-in method release of thread.lock object at remote 0x55731187e810>) at remote 0x557311de6850>, _Thread__name='pulp.task', _Thread__daemonic=True, reader=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, _impl=<Reader(url='qpid+ssl://oser501800.wal-mart.com:5671', node=<...>, connection=<Connection(url='qpid+ssl://oser501800.wal-mart.com:5671', _impl=<Connection(get_error=<function at remote 0x7f09d80d5b90>, protocol=None, _ssl_skip_h...(truncated)

self.__bootstrap_inner()