Skip to content

Instantly share code, notes, and snippets.

@shenoy-anurag
Created August 4, 2020 14:11
Show Gist options
  • Save shenoy-anurag/b3d0c6b5ba08c979446d6758ba7a365c to your computer and use it in GitHub Desktop.
Save shenoy-anurag/b3d0c6b5ba08c979446d6758ba7a365c to your computer and use it in GitHub Desktop.
amqp.exceptions.RecoverableConnectionError: Socket was disconnected
[2020-07-31 15:46:57,623: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(332)start()
-> self.on_close()
[2020-07-31 15:46:57,624: WARNING/MainProcess] (Pdb)
nn
[2020-07-31 15:47:13,396: WARNING/MainProcess] ***
[2020-07-31 15:47:13,397: WARNING/MainProcess] NameError: name 'nn' is not defined
[2020-07-31 15:47:13,397: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:16,017: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(333)start()
-> blueprint.restart(self)
[2020-07-31 15:47:16,018: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:17,817: DEBUG/MainProcess] | Consumer: Restarting event loop...
[2020-07-31 15:47:17,818: DEBUG/MainProcess] | Consumer: Restarting Heart...
[2020-07-31 15:47:17,821: DEBUG/MainProcess] | Consumer: Restarting Control...
[2020-07-31 15:47:17,824: DEBUG/MainProcess] | Consumer: Restarting Tasks...
[2020-07-31 15:47:17,825: DEBUG/MainProcess] Canceling task consumer...
[2020-07-31 15:47:17,826: DEBUG/MainProcess] | Consumer: Restarting Gossip...
[2020-07-31 15:47:17,827: DEBUG/MainProcess] | Consumer: Restarting Mingle...
[2020-07-31 15:47:17,828: DEBUG/MainProcess] | Consumer: Restarting Events...
[2020-07-31 15:47:17,828: DEBUG/MainProcess] | Consumer: Restarting Connection...
[2020-07-31 15:47:17,828: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(308)start()
-> while blueprint.state not in STOP_CONDITIONS:
[2020-07-31 15:47:17,829: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:26,767: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(309)start()
-> maybe_shutdown()
[2020-07-31 15:47:26,767: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:28,673: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(310)start()
-> if self.restart_count:
[2020-07-31 15:47:28,673: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:30,766: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(311)start()
-> try:
[2020-07-31 15:47:30,766: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:31,741: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(312)start()
-> self._restart_state.step()
[2020-07-31 15:47:31,742: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:32,573: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(316)start()
-> self.restart_count += 1
[2020-07-31 15:47:32,573: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:33,572: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(317)start()
-> try:
[2020-07-31 15:47:33,573: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:34,364: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(318)start()
-> blueprint.start(self)
[2020-07-31 15:47:34,364: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:47:35,188: DEBUG/MainProcess] | Consumer: Starting Connection
[2020-07-31 15:47:35,201: DEBUG/MainProcess] Start from server, version: 0.9, properties: {'capabilities': {'publisher_confirms': True, 'exchange_exchange_bindings': True, 'basic.nack': True, 'consumer_cancel_notify': True, 'connection.blocked': True, 'consumer_priorities': True, 'authentication_failure_close': True, 'per_consumer_qos': True, 'direct_reply_to': True}, 'cluster_name': 'rabbit@rabbitmq', 'copyright': 'Copyright (c) 2007-2020 VMware, Inc. or its affiliates.', 'information': 'Licensed under the MPL 1.1. Website: https://rabbitmq.com', 'platform': 'Erlang/OTP 23.0.3', 'product': 'RabbitMQ', 'version': '3.8.5'}, mechanisms: [b'PLAIN', b'AMQPLAIN'], locales: ['en_US']
[2020-07-31 15:47:35,205: INFO/MainProcess] Connected to amqp://guest:**@rabbitmq:5672//
[2020-07-31 15:47:35,205: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:35,205: DEBUG/MainProcess] | Consumer: Starting Events
[2020-07-31 15:47:35,208: DEBUG/MainProcess] Closed channel #1
[2020-07-31 15:47:35,223: DEBUG/MainProcess] Start from server, version: 0.9, properties: {'capabilities': {'publisher_confirms': True, 'exchange_exchange_bindings': True, 'basic.nack': True, 'consumer_cancel_notify': True, 'connection.blocked': True, 'consumer_priorities': True, 'authentication_failure_close': True, 'per_consumer_qos': True, 'direct_reply_to': True}, 'cluster_name': 'rabbit@rabbitmq', 'copyright': 'Copyright (c) 2007-2020 VMware, Inc. or its affiliates.', 'information': 'Licensed under the MPL 1.1. Website: https://rabbitmq.com', 'platform': 'Erlang/OTP 23.0.3', 'product': 'RabbitMQ', 'version': '3.8.5'}, mechanisms: [b'PLAIN', b'AMQPLAIN'], locales: ['en_US']
[2020-07-31 15:47:35,226: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:35,227: DEBUG/MainProcess] | Consumer: Starting Mingle
[2020-07-31 15:47:35,227: INFO/MainProcess] mingle: searching for neighbors
[2020-07-31 15:47:35,228: DEBUG/MainProcess] using channel_id: 1
[2020-07-31 15:47:35,231: DEBUG/MainProcess] Channel open
[2020-07-31 15:47:35,252: DEBUG/MainProcess] Start from server, version: 0.9, properties: {'capabilities': {'publisher_confirms': True, 'exchange_exchange_bindings': True, 'basic.nack': True, 'consumer_cancel_notify': True, 'connection.blocked': True, 'consumer_priorities': True, 'authentication_failure_close': True, 'per_consumer_qos': True, 'direct_reply_to': True}, 'cluster_name': 'rabbit@rabbitmq', 'copyright': 'Copyright (c) 2007-2020 VMware, Inc. or its affiliates.', 'information': 'Licensed under the MPL 1.1. Website: https://rabbitmq.com', 'platform': 'Erlang/OTP 23.0.3', 'product': 'RabbitMQ', 'version': '3.8.5'}, mechanisms: [b'PLAIN', b'AMQPLAIN'], locales: ['en_US']
[2020-07-31 15:47:35,255: DEBUG/MainProcess] using channel_id: 1
[2020-07-31 15:47:35,257: DEBUG/MainProcess] Channel open
[2020-07-31 15:47:35,261: DEBUG/MainProcess] Closed channel #1
[2020-07-31 15:47:36,308: INFO/MainProcess] mingle: all alone
[2020-07-31 15:47:36,308: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:36,309: DEBUG/MainProcess] | Consumer: Starting Gossip
[2020-07-31 15:47:36,309: DEBUG/MainProcess] using channel_id: 2
[2020-07-31 15:47:36,311: DEBUG/MainProcess] Channel open
[2020-07-31 15:47:36,320: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:36,321: DEBUG/MainProcess] | Consumer: Starting Tasks
[2020-07-31 15:47:36,378: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:36,379: DEBUG/MainProcess] | Consumer: Starting Control
[2020-07-31 15:47:36,380: DEBUG/MainProcess] using channel_id: 3
[2020-07-31 15:47:36,381: DEBUG/MainProcess] Channel open
[2020-07-31 15:47:36,386: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:36,387: DEBUG/MainProcess] | Consumer: Starting Heart
[2020-07-31 15:47:36,388: DEBUG/MainProcess] using channel_id: 1
[2020-07-31 15:47:36,390: DEBUG/MainProcess] Channel open
[2020-07-31 15:47:36,392: DEBUG/MainProcess] ^-- substep ok
[2020-07-31 15:47:36,392: DEBUG/MainProcess] | Consumer: Starting event loop
[2020-07-31 15:47:36,393: DEBUG/MainProcess] | Worker: Hub.register Pool...
[2020-07-31 15:47:36,395: DEBUG/MainProcess] basic.qos: prefetch_count->4
[2020-07-31 15:47:36,397: INFO/MainProcess] Received task: long_running_task[623813b0-3b69-4728-a27f-1150a3aa25f1]
[2020-07-31 15:47:36,404: DEBUG/MainProcess] TaskPool: Apply <function _fast_trace_task at 0x7fded372ce18> (args:('long_running_task', '623813b0-3b69-4728-a27f-1150a3aa25f1', {'lang': 'py', 'task': 'long_running_task', 'id': '623813b0-3b69-4728-a27f-1150a3aa25f1', 'shadow': None, 'eta': None, 'expires': None, 'group': None, 'retries': 0, 'timelimit': [None, None], 'root_id': '623813b0-3b69-4728-a27f-1150a3aa25f1', 'parent_id': None, 'argsrepr': '()', 'kwargsrepr': "{'n': 30}", 'origin': 'gen6@0736f621fc77', 'reply_to': '60b99528-066b-378b-be49-3348e1fda267', 'correlation_id': '623813b0-3b69-4728-a27f-1150a3aa25f1', 'hostname': 'celery@5da7711becb9', 'delivery_info': {'exchange': '', 'routing_key': 'celery', 'priority': 0, 'redelivered': True}, 'args': [], 'kwargs': {'n': 30}}, '[[], {"n": 30}, {"callbacks": null, "errbacks": null, "chain": null, "chord": null}]', 'application/json', 'utf-8') kwargs:{})
[2020-07-31 15:47:36,405: DEBUG/MainProcess] Task accepted: long_running_task[623813b0-3b69-4728-a27f-1150a3aa25f1] pid:6
[2020-07-31 15:47:36,406: WARNING/MainProcess] This task will take: 30 seconds
[2020-07-31 15:47:36,406: WARNING/MainProcess] Task started
[2020-07-31 15:47:36,407: WARNING/MainProcess] 0
[2020-07-31 15:47:46,418: WARNING/MainProcess] 10
[2020-07-31 15:47:56,429: WARNING/MainProcess] 20
[2020-07-31 15:48:06,440: WARNING/MainProcess] > /app/celery_config/celery_tasks.py(122)long_running_task()
-> print("All done")
[2020-07-31 15:48:06,440: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:12,828: WARNING/MainProcess] All done
[2020-07-31 15:48:12,828: WARNING/MainProcess] --Return--
[2020-07-31 15:48:12,829: WARNING/MainProcess] > /app/celery_config/celery_tasks.py(122)long_running_task()->None
-> print("All done")
[2020-07-31 15:48:12,829: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:13,378: WARNING/MainProcess] --Call--
[2020-07-31 15:48:13,378: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/flask/ctx.py(248)__exit__()
-> def __exit__(self, exc_type, exc_value, tb):
[2020-07-31 15:48:13,379: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:14,351: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/flask/ctx.py(249)__exit__()
-> self.pop(exc_value)
[2020-07-31 15:48:14,351: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:14,930: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/flask/ctx.py(251)__exit__()
-> if BROKEN_PYPY_CTXMGR_EXIT and exc_type is not None:
[2020-07-31 15:48:14,931: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:15,274: WARNING/MainProcess] --Return--
[2020-07-31 15:48:15,274: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/flask/ctx.py(251)__exit__()->None
-> if BROKEN_PYPY_CTXMGR_EXIT and exc_type is not None:
[2020-07-31 15:48:15,275: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:15,673: WARNING/MainProcess] --Return--
[2020-07-31 15:48:15,673: WARNING/MainProcess] > /app/celery_config/celery_worker.py(15)__call__()->None
-> return self.run(*args, **kwargs)
[2020-07-31 15:48:15,673: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:16,047: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(413)trace_task()
-> state = SUCCESS
[2020-07-31 15:48:16,048: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:16,415: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(434)trace_task()
-> try:
[2020-07-31 15:48:16,416: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:16,933: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(442)trace_task()
-> callbacks = task.request.callbacks
[2020-07-31 15:48:16,933: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:17,402: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(443)trace_task()
-> if callbacks:
[2020-07-31 15:48:17,403: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:17,790: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(471)trace_task()
-> chain = task_request.chain
[2020-07-31 15:48:17,791: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:18,135: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(472)trace_task()
-> if chain:
[2020-07-31 15:48:18,135: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:18,512: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(479)trace_task()
-> mark_as_done(
[2020-07-31 15:48:18,513: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:18,849: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(480)trace_task()
-> uuid, retval, task_request, publish_result,
[2020-07-31 15:48:18,849: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:20,081: DEBUG/MainProcess] Start from server, version: 0.9, properties: {'capabilities': {'publisher_confirms': True, 'exchange_exchange_bindings': True, 'basic.nack': True, 'consumer_cancel_notify': True, 'connection.blocked': True, 'consumer_priorities': True, 'authentication_failure_close': True, 'per_consumer_qos': True, 'direct_reply_to': True}, 'cluster_name': 'rabbit@rabbitmq', 'copyright': 'Copyright (c) 2007-2020 VMware, Inc. or its affiliates.', 'information': 'Licensed under the MPL 1.1. Website: https://rabbitmq.com', 'platform': 'Erlang/OTP 23.0.3', 'product': 'RabbitMQ', 'version': '3.8.5'}, mechanisms: [b'PLAIN', b'AMQPLAIN'], locales: ['en_US']
[2020-07-31 15:48:20,083: DEBUG/MainProcess] using channel_id: 1
[2020-07-31 15:48:20,085: DEBUG/MainProcess] Channel open
[2020-07-31 15:48:20,090: DEBUG/MainProcess] Closed channel #1
[2020-07-31 15:48:20,091: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(485)trace_task()
-> Rstr = saferepr(R, resultrepr_maxsize)
[2020-07-31 15:48:20,091: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:22,335: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(486)trace_task()
-> T = monotonic() - time_start
[2020-07-31 15:48:22,336: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:23,059: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(487)trace_task()
-> if task_on_success:
[2020-07-31 15:48:23,060: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:23,467: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(489)trace_task()
-> if success_receivers:
[2020-07-31 15:48:23,468: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:24,272: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(491)trace_task()
-> if _does_info:
[2020-07-31 15:48:24,273: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:24,728: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(492)trace_task()
-> info(LOG_SUCCESS, {
[2020-07-31 15:48:24,728: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:25,125: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(493)trace_task()
-> 'id': uuid,
[2020-07-31 15:48:25,125: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:25,818: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(494)trace_task()
-> 'name': get_task_name(task_request, name),
[2020-07-31 15:48:25,819: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:26,896: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(495)trace_task()
-> 'return_value': Rstr,
[2020-07-31 15:48:26,897: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:27,456: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(496)trace_task()
-> 'runtime': T,
[2020-07-31 15:48:27,456: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:27,975: INFO/MainProcess] Task long_running_task[623813b0-3b69-4728-a27f-1150a3aa25f1] succeeded in 46.65342097300163s: None
[2020-07-31 15:48:27,975: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(500)trace_task()
-> if state not in IGNORE_STATES:
[2020-07-31 15:48:27,976: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:31,377: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(501)trace_task()
-> if task_after_return:
[2020-07-31 15:48:31,378: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:32,165: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(506)trace_task()
-> try:
[2020-07-31 15:48:32,165: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:32,745: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(507)trace_task()
-> if postrun_receivers:
[2020-07-31 15:48:32,746: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:33,283: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(512)trace_task()
-> pop_task()
[2020-07-31 15:48:33,284: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:34,737: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(513)trace_task()
-> pop_request()
[2020-07-31 15:48:34,737: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:35,125: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(514)trace_task()
-> if not eager:
[2020-07-31 15:48:35,126: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:35,494: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(515)trace_task()
-> try:
[2020-07-31 15:48:35,495: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:36,083: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(516)trace_task()
-> backend_cleanup()
[2020-07-31 15:48:36,083: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:36,643: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(517)trace_task()
-> loader_cleanup()
[2020-07-31 15:48:36,643: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:37,205: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(532)trace_task()
-> return trace_ok_t(R, I, T, Rstr)
[2020-07-31 15:48:37,206: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:37,801: WARNING/MainProcess] --Return--
[2020-07-31 15:48:37,801: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(532)trace_task()->trace_ok_t(re...retstr='None')
-> return trace_ok_t(R, I, T, Rstr)
[2020-07-31 15:48:37,802: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:38,437: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(614)_fast_trace_task()
-> return (1, R, T) if I else (0, Rstr, T)
[2020-07-31 15:48:38,437: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:41,466: WARNING/MainProcess] --Return--
[2020-07-31 15:48:41,466: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/app/trace.py(614)_fast_trace_task()->(0, 'None', 46.65342097300163)
-> return (1, R, T) if I else (0, Rstr, T)
[2020-07-31 15:48:41,467: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:41,922: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/concurrency/base.py(46)apply_target()
-> callback(ret)
[2020-07-31 15:48:41,922: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:42,429: WARNING/MainProcess] --Return--
[2020-07-31 15:48:42,430: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/concurrency/base.py(46)apply_target()->None
-> callback(ret)
[2020-07-31 15:48:42,430: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:42,951: WARNING/MainProcess] --Return--
[2020-07-31 15:48:42,951: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/concurrency/base.py(158)apply_async()->None
-> **options)
[2020-07-31 15:48:42,952: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:43,439: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/request.py(656)execute_using_pool()
-> self._apply_result = maybe(ref, result)
[2020-07-31 15:48:43,439: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:44,170: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/request.py(657)execute_using_pool()
-> return result
[2020-07-31 15:48:44,171: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:44,812: WARNING/MainProcess] --Return--
[2020-07-31 15:48:44,813: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/request.py(657)execute_using_pool()->None
-> return result
[2020-07-31 15:48:44,814: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:45,420: WARNING/MainProcess] --Return--
[2020-07-31 15:48:45,421: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/worker.py(231)_process_task()->None
-> req.execute_using_pool(self.pool)
[2020-07-31 15:48:45,422: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:46,033: WARNING/MainProcess] --Return--
[2020-07-31 15:48:46,034: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/strategy.py(203)task_message_handler()->None
-> handle(req)
[2020-07-31 15:48:46,035: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:46,764: WARNING/MainProcess] --Return--
[2020-07-31 15:48:46,765: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/celery/worker/consumer/consumer.py(571)on_task_received()->None
-> callbacks,
[2020-07-31 15:48:46,766: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:47,364: WARNING/MainProcess] --Return--
[2020-07-31 15:48:47,364: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/kombu/messaging.py(624)_receive_callback()->None
-> return on_m(message) if on_m else self.receive(decoded, message)
[2020-07-31 15:48:47,365: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:48,110: WARNING/MainProcess] --Return--
[2020-07-31 15:48:48,111: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/channel.py(1615)_on_basic_deliver()->None
-> fun(msg)
[2020-07-31 15:48:48,111: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:48,822: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/abstract_channel.py(144)dispatch_method()
-> for listener in listeners:
[2020-07-31 15:48:48,823: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:49,525: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/abstract_channel.py(147)dispatch_method()
-> if one_shot:
[2020-07-31 15:48:49,525: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:50,112: WARNING/MainProcess] --Return--
[2020-07-31 15:48:50,112: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/abstract_channel.py(147)dispatch_method()->None
-> if one_shot:
[2020-07-31 15:48:50,113: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:50,612: WARNING/MainProcess] --Return--
[2020-07-31 15:48:50,612: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/connection.py(521)on_inbound_method()->None
-> method_sig, payload, content,
[2020-07-31 15:48:50,612: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:51,120: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/method_framing.py(83)on_frame()
-> return True
[2020-07-31 15:48:51,120: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:54,081: WARNING/MainProcess] --Return--
[2020-07-31 15:48:54,081: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/method_framing.py(83)on_frame()->True
-> return True
[2020-07-31 15:48:54,082: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:57,396: WARNING/MainProcess] --Return--
[2020-07-31 15:48:57,397: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/connection.py(514)blocking_read()->True
-> return self.on_inbound_frame(frame)
[2020-07-31 15:48:57,397: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:59,247: WARNING/MainProcess] --Return--
[2020-07-31 15:48:59,248: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/connection.py(508)drain_events()->None
-> while not self.blocking_read(timeout):
[2020-07-31 15:48:59,248: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:48:59,726: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/abstract_channel.py(87)wait()
-> while not p.ready:
[2020-07-31 15:48:59,726: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:49:00,225: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/abstract_channel.py(88)wait()
-> self.connection.drain_events(timeout=timeout)
[2020-07-31 15:49:00,225: WARNING/MainProcess] (Pdb)
n
[2020-07-31 15:49:01,090: WARNING/MainProcess] > /usr/local/lib/python3.6/dist-packages/amqp/abstract_channel.py(87)wait()
-> while not p.ready:
[2020-07-31 15:49:01,091: WARNING/MainProcess] (Pdb)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment