<h1 dir="auto">Checklist</h1>

<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have verified that the issue exists against the <code class="notranslate">master</code> branch of Celery.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have checked the<br>
<a href="https://github.com/celery/celery/issues/3932/" data-hovercard-type="issue" data-hovercard-url="/celery/celery/issues/3932/hovercard">celery issues 3932</a><br>
<a href="https://github.com/celery/kombu/issues/931" data-hovercard-type="issue" data-hovercard-url="/celery/kombu/issues/931/hovercard">kombu issue 931</a><br>
for similar or identical bug reports.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have included all related issues and possible duplicate issues<br>
in this issue (If there are none, check this box anyway).</li>
</ul>
<h2 dir="auto">Mandatory Debugging Information</h2>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have included the output of <code class="notranslate">celery -A proj report</code> in the issue.<br>
(if you are not able to do this, then at least specify the Celery<br>
version affected).</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have verified that the issue exists against the <code class="notranslate">master</code> branch of Celery.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have included the contents of <code class="notranslate">pip freeze</code> in the issue.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have included all the versions of all the external dependencies required<br>
to reproduce this bug.</li>
</ul>
<h2 dir="auto">Related Issues and Possible Duplicates</h2>

<h4 dir="auto">Related Issues</h4>
<ul dir="auto">
<li><a class="issue-link js-issue-link" data-error-text="Failed to load title" data-id="216299501" data-permission-text="Title is private" data-url="https://github.com/celery/celery/issues/3932" data-hovercard-type="issue" data-hovercard-url="/celery/celery/issues/3932/hovercard" href="https://github.com/celery/celery/issues/3932">#3932</a></li>
<li><a class="issue-link js-issue-link" data-error-text="Failed to load title" data-id="370842185" data-permission-text="Title is private" data-url="https://github.com/celery/kombu/issues/931" data-hovercard-type="issue" data-hovercard-url="/celery/kombu/issues/931/hovercard" href="https://github.com/celery/kombu/issues/931">celery/kombu#931</a></li>
</ul>
<h4 dir="auto">Possible Duplicates</h4>
<ul dir="auto">
<li>None</li>
</ul>
<h2 dir="auto">Environment &amp; Settings</h2>

<p dir="auto"><strong>Celery version</strong>:</p>

<details>
<summary><b><code class="notranslate">celery report</code> Output:</b></summary>
<p dir="auto">
</p><div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="software -&gt; celery:4.4.2 (cliffs) kombu:4.6.11 py:3.7.6
            billiard:3.6.3.0 py-amqp:2.6.0
platform -&gt; system:Linux arch:64bit
            kernel version:4.15.0-1065-aws imp:CPython
loader   -&gt; celery.loaders.default.Loader
settings -&gt; transport:amqp results:disabled"><pre class="notranslate"><code class="notranslate">software -&gt; celery:4.4.2 (cliffs) kombu:4.6.11 py:3.7.6
            billiard:3.6.3.0 py-amqp:2.6.0
platform -&gt; system:Linux arch:64bit
            kernel version:4.15.0-1065-aws imp:CPython
loader   -&gt; celery.loaders.default.Loader
settings -&gt; transport:amqp results:disabled
</code></pre></div>
<p dir="auto"></p>
</details>
<h1 dir="auto">Steps to Reproduce</h1>
<h2 dir="auto">Required Dependencies</h2>

<ul dir="auto">
<li><strong>Minimal Python Version</strong>: 3.7.6 imp: CPython</li>
<li><strong>Minimal Celery Version</strong>: 4.4.2</li>
<li><strong>Minimal Kombu Version</strong>: 4.6.11</li>
<li><strong>Minimal Broker Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Result Backend Version</strong>: N/A or Unknown</li>
<li><strong>Minimal OS and/or Kernel Version</strong>: GNU Linux Ubuntu x86_64 18.04</li>
<li><strong>Minimal Broker Client Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Result Backend Client Version</strong>: N/A or Unknown</li>
</ul>
<h3 dir="auto">Python Packages</h3>

<details>
<summary><b><code class="notranslate">pip freeze</code> Output:</b></summary>
<p dir="auto">
</p><div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="aiohttp==3.6.2
amqp==2.6.0
argh==0.26.2
asgiref==3.2.10
async-timeout==3.0.1
attrs==19.3.0
billiard==3.6.3.0
boto3==1.12.39
botocore==1.15.49
celery==4.4.2
certifi==2020.6.20
chardet==3.0.4
ddtrace==0.37.0
Django==3.0.4
docutils==0.15.2
future==0.18.2
gunicorn==20.0.4
idna==2.10
jmespath==0.10.0
kombu==4.6.11
msgpack==1.0.0
multidict==4.7.6
pathtools==0.1.2
psycopg2-binary==2.8.4
python-dateutil==2.8.1
python-dotenv==0.12.0
pytz==2020.1
PyYAML==5.3.1
requests==2.23.0
s3transfer==0.3.3
setproctitle==1.1.10
six==1.15.0
slackclient==2.5.0
sqlparse==0.3.1
urllib3==1.25.9
vine==1.3.0
yarl==1.4.2"><pre class="notranslate"><code class="notranslate">aiohttp==3.6.2
amqp==2.6.0
argh==0.26.2
asgiref==3.2.10
async-timeout==3.0.1
attrs==19.3.0
billiard==3.6.3.0
boto3==1.12.39
botocore==1.15.49
celery==4.4.2
certifi==2020.6.20
chardet==3.0.4
ddtrace==0.37.0
Django==3.0.4
docutils==0.15.2
future==0.18.2
gunicorn==20.0.4
idna==2.10
jmespath==0.10.0
kombu==4.6.11
msgpack==1.0.0
multidict==4.7.6
pathtools==0.1.2
psycopg2-binary==2.8.4
python-dateutil==2.8.1
python-dotenv==0.12.0
pytz==2020.1
PyYAML==5.3.1
requests==2.23.0
s3transfer==0.3.3
setproctitle==1.1.10
six==1.15.0
slackclient==2.5.0
sqlparse==0.3.1
urllib3==1.25.9
vine==1.3.0
yarl==1.4.2
</code></pre></div>
<p dir="auto"></p>
</details>
<h3 dir="auto">Other Dependencies</h3>

<details>
<p dir="auto">
N/A
</p>
</details>
<h2 dir="auto">Minimally Reproducible Test Case</h2>

<details>
<p dir="auto">
It depends. The issue is occurring when we will get a connection lost error.
```python
```
</p>
</details>
<h1 dir="auto">Expected Behavior</h1>

<h1 dir="auto">Actual Behavior</h1>
<p dir="auto">Got this in logs.</p>
<div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="[2020-06-03 01:36:35,499: WARNING/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection...
Traceback (most recent call last):
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connection.py&quot;, line 160, in _new_conn
    (self._dns_host, self.port), self.timeout, **extra_kw
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/util/connection.py&quot;, line 61, in create_connection
    for res in socket.getaddrinfo(host, port, family, socket.SOCK_STREAM):
  File &quot;/opt/pyenv/versions/3.7.6/lib/python3.7/socket.py&quot;, line 752, in getaddrinfo
    for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
socket.gaierror: [Errno -3] Temporary failure in name resolution

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/httpsession.py&quot;, line 263, in send
    chunked=self._chunked(request.headers),
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py&quot;, line 725, in urlopen
    method, url, error=e, _pool=self, _stacktrace=sys.exc_info()[2]
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/util/retry.py&quot;, line 379, in increment
    raise six.reraise(type(error), error, _stacktrace)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/packages/six.py&quot;, line 735, in reraise
    raise value
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py&quot;, line 677, in urlopen
    chunked=chunked,
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py&quot;, line 381, in _make_request
    self._validate_conn(conn)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py&quot;, line 976, in _validate_conn
    conn.connect()
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connection.py&quot;, line 308, in connect
    conn = self._new_conn()
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connection.py&quot;, line 172, in _new_conn
    self, &quot;Failed to establish a new connection: %s&quot; % e
urllib3.exceptions.NewConnectionError: &lt;botocore.awsrequest.AWSHTTPSConnection object at 0x7f910d7373d0&gt;: Failed to establish a new connection: [Errno -3] Temporary failure in name resolution

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/worker/consumer/consumer.py&quot;, line 318, in start
    blueprint.start(self)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/bootsteps.py&quot;, line 119, in start
    step.start(parent)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/worker/consumer/consumer.py&quot;, line 599, in start
    c.loop(*c.loop_args())
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/worker/loops.py&quot;, line 83, in asynloop
    next(loop)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/asynchronous/hub.py&quot;, line 301, in create_loop
    item()
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/vine/promises.py&quot;, line 170, in __call__
    return self.throw()
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/vine/promises.py&quot;, line 167, in __call__
    retval = fun(*final_args, **final_kwargs)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py&quot;, line 390, in _schedule_queue
    queue, callback=promise(self._loop1, (queue,)),
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py&quot;, line 406, in _get_bulk_async
    return self._get_async(queue, maxcount, callback=callback)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py&quot;, line 417, in _get_async
    callback=transform(self._on_messages_ready, callback, q, queue),
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py&quot;, line 442, in _get_from_sqs
    queue_url = connection.get_queue_url(queue)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/asynchronous/aws/sqs/connection.py&quot;, line 45, in get_queue_url
    res = self.sqs_connection.get_queue_url(QueueName=queue)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/client.py&quot;, line 316, in _api_call
    return self._make_api_call(operation_name, kwargs)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/ddtrace/contrib/botocore/patch.py&quot;, line 70, in patched_api_call
    result = original_func(*args, **kwargs)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/client.py&quot;, line 613, in _make_api_call
    operation_model, request_dict, request_context)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/client.py&quot;, line 632, in _make_request
    return self._endpoint.make_request(operation_model, request_dict)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py&quot;, line 102, in make_request
    return self._send_request(request_dict, operation_model)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py&quot;, line 137, in _send_request
    success_response, exception):
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py&quot;, line 231, in _needs_retry
    caught_exception=caught_exception, request_dict=request_dict)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/hooks.py&quot;, line 356, in emit
    return self._emitter.emit(aliased_event_name, **kwargs)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/hooks.py&quot;, line 228, in emit
    return self._emit(event_name, kwargs)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/hooks.py&quot;, line 211, in _emit
    response = handler(**kwargs)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py&quot;, line 183, in __call__
    if self._checker(attempts, response, caught_exception):
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py&quot;, line 251, in __call__
    caught_exception)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py&quot;, line 277, in _should_retry
    return self._checker(attempt_number, response, caught_exception)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py&quot;, line 317, in __call__
    caught_exception)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py&quot;, line 223, in __call__
    attempt_number, caught_exception)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py&quot;, line 359, in _check_caught_exception
    raise caught_exception
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py&quot;, line 200, in _do_get_response
    http_response = self._send(request)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py&quot;, line 244, in _send
    return self.http_session.send(request)
  File &quot;/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/httpsession.py&quot;, line 283, in send
    raise EndpointConnectionError(endpoint_url=request.url, error=e)
botocore.exceptions.EndpointConnectionError: Could not connect to the endpoint URL: &quot;https://queue.amazonaws.com/&quot;
[2020-06-03 01:36:47,080: ERROR/MainProcess] consumer: Cannot connect to sqs://localhost//: Could not connect to the endpoint URL: &quot;https://queue.amazonaws.com/&quot;.
Trying again in 2.00 seconds... (1/100)

[2020-06-03 01:36:57,674: INFO/MainProcess] Connected to sqs://localhost//
"><pre class="notranslate"><code class="notranslate">[2020-06-03 01:36:35,499: WARNING/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection...
Traceback (most recent call last):
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connection.py", line 160, in _new_conn
    (self._dns_host, self.port), self.timeout, **extra_kw
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/util/connection.py", line 61, in create_connection
    for res in socket.getaddrinfo(host, port, family, socket.SOCK_STREAM):
  File "/opt/pyenv/versions/3.7.6/lib/python3.7/socket.py", line 752, in getaddrinfo
    for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
socket.gaierror: [Errno -3] Temporary failure in name resolution

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/httpsession.py", line 263, in send
    chunked=self._chunked(request.headers),
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py", line 725, in urlopen
    method, url, error=e, _pool=self, _stacktrace=sys.exc_info()[2]
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/util/retry.py", line 379, in increment
    raise six.reraise(type(error), error, _stacktrace)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/packages/six.py", line 735, in reraise
    raise value
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py", line 677, in urlopen
    chunked=chunked,
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py", line 381, in _make_request
    self._validate_conn(conn)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connectionpool.py", line 976, in _validate_conn
    conn.connect()
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connection.py", line 308, in connect
    conn = self._new_conn()
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/urllib3/connection.py", line 172, in _new_conn
    self, "Failed to establish a new connection: %s" % e
urllib3.exceptions.NewConnectionError: &lt;botocore.awsrequest.AWSHTTPSConnection object at 0x7f910d7373d0&gt;: Failed to establish a new connection: [Errno -3] Temporary failure in name resolution

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/worker/consumer/consumer.py", line 318, in start
    blueprint.start(self)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/bootsteps.py", line 119, in start
    step.start(parent)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/worker/consumer/consumer.py", line 599, in start
    c.loop(*c.loop_args())
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/celery/worker/loops.py", line 83, in asynloop
    next(loop)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/asynchronous/hub.py", line 301, in create_loop
    item()
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/vine/promises.py", line 170, in __call__
    return self.throw()
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/vine/promises.py", line 167, in __call__
    retval = fun(*final_args, **final_kwargs)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py", line 390, in _schedule_queue
    queue, callback=promise(self._loop1, (queue,)),
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py", line 406, in _get_bulk_async
    return self._get_async(queue, maxcount, callback=callback)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py", line 417, in _get_async
    callback=transform(self._on_messages_ready, callback, q, queue),
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/transport/SQS.py", line 442, in _get_from_sqs
    queue_url = connection.get_queue_url(queue)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/kombu/asynchronous/aws/sqs/connection.py", line 45, in get_queue_url
    res = self.sqs_connection.get_queue_url(QueueName=queue)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/client.py", line 316, in _api_call
    return self._make_api_call(operation_name, kwargs)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/ddtrace/contrib/botocore/patch.py", line 70, in patched_api_call
    result = original_func(*args, **kwargs)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/client.py", line 613, in _make_api_call
    operation_model, request_dict, request_context)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/client.py", line 632, in _make_request
    return self._endpoint.make_request(operation_model, request_dict)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py", line 102, in make_request
    return self._send_request(request_dict, operation_model)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py", line 137, in _send_request
    success_response, exception):
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py", line 231, in _needs_retry
    caught_exception=caught_exception, request_dict=request_dict)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/hooks.py", line 356, in emit
    return self._emitter.emit(aliased_event_name, **kwargs)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/hooks.py", line 228, in emit
    return self._emit(event_name, kwargs)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/hooks.py", line 211, in _emit
    response = handler(**kwargs)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py", line 183, in __call__
    if self._checker(attempts, response, caught_exception):
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py", line 251, in __call__
    caught_exception)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py", line 277, in _should_retry
    return self._checker(attempt_number, response, caught_exception)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py", line 317, in __call__
    caught_exception)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py", line 223, in __call__
    attempt_number, caught_exception)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/retryhandler.py", line 359, in _check_caught_exception
    raise caught_exception
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py", line 200, in _do_get_response
    http_response = self._send(request)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/endpoint.py", line 244, in _send
    return self.http_session.send(request)
  File "/home/$USER/.local/share/virtualenvs/$PROJECT_NAME-zlr2NI-5/lib/python3.7/site-packages/botocore/httpsession.py", line 283, in send
    raise EndpointConnectionError(endpoint_url=request.url, error=e)
botocore.exceptions.EndpointConnectionError: Could not connect to the endpoint URL: "https://queue.amazonaws.com/"
[2020-06-03 01:36:47,080: ERROR/MainProcess] consumer: Cannot connect to sqs://localhost//: Could not connect to the endpoint URL: "https://queue.amazonaws.com/".
Trying again in 2.00 seconds... (1/100)

[2020-06-03 01:36:57,674: INFO/MainProcess] Connected to sqs://localhost//

</code></pre></div>
<p dir="auto">And after the last line logs are empty because celery stops handling any message.</p>
<h1 dir="auto">Checklist</h1>

<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have read the relevant section in the<br>
<a href="http://docs.celeryproject.org/en/latest/contributing.html#other-bugs" rel="nofollow">contribution guide</a><br>
on reporting bugs.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have checked the <a href="https://github.com/celery/celery/issues?q=is%3Aissue+label%3A%22Issue+Type%3A+Bug+Report%22+-label%3A%22Category%3A+Documentation%22">issues list</a><br>
for similar or identical bug reports.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have checked the <a href="https://github.com/celery/celery/pulls?q=is%3Apr+label%3A%22PR+Type%3A+Bugfix%22+-label%3A%22Category%3A+Documentation%22">pull requests list</a><br>
for existing proposed fixes.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have checked the <a href="https://github.com/celery/celery/commits/master">commit log</a><br>
to find out if the bug was already fixed in the master branch.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have included all related issues and possible duplicate issues<br>
in this issue (If there are none, check this box anyway).</li>
</ul>
<h2 dir="auto">Mandatory Debugging Information</h2>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I have included the output of <code class="notranslate">celery -A proj report</code> in the issue.<br>
(if you are not able to do this, then at least specify the Celery<br>
version affected).</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have verified that the issue exists against the <code class="notranslate">master</code> branch of Celery.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have included the contents of <code class="notranslate">pip freeze</code> in the issue.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have included all the versions of all the external dependencies required<br>
to reproduce this bug.</li>
</ul>
<h2 dir="auto">Optional Debugging Information</h2>

<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue on more than one Python version<br>
and/or implementation.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue on more than one message broker and/or<br>
result backend.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue on more than one version of the message<br>
broker and/or result backend.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue on more than one operating system.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue on more than one workers pool.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue with autoscaling, retries,<br>
ETA/Countdown &amp; rate limits disabled.</li>
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> I have tried reproducing the issue after downgrading<br>
and/or upgrading Celery and its dependencies.</li>
</ul>
<h2 dir="auto">Related Issues and Possible Duplicates</h2>

<h4 dir="auto">Related Issues</h4>
<ul dir="auto">
<li>None</li>
</ul>
<h4 dir="auto">Possible Duplicates</h4>
<ul dir="auto">
<li>None</li>
</ul>
<h2 dir="auto">Environment &amp; Settings</h2>

<p dir="auto"><strong>Celery version</strong>:</p>

<details>
<summary><b><code class="notranslate">celery report</code> Output:software -&gt; celery:4.3.0 (rhubarb) kombu:4.6.3 py:3.6.5
            billiard:3.6.0.0 py-amqp:2.5.0
platform -&gt; system:Linux arch:64bit
            kernel version:4.15.0-54-generic imp:CPython
loader   -&gt; celery.loaders.app.AppLoader
settings -&gt; transport:amqp results:rpc:///
</b><p dir="auto"><b>accept_content: ['pickle']<br>
broker_url: 'amqp://amitc005:********<a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url="/users/localhost/hovercard" data-octo-click="hovercard-link-click" data-octo-dimensions="link_type:self" href="https://github.com/localhost">@localhost</a>:5672/rest'<br>
include: ['srm_rest_email.email.views']<br>
result_backend: 'rpc:///'<br>
result_expires: 3000<br>
result_extended: True<br>
task_default_queue: 'email'<br>
task_serializer: 'pickle'<br>
task_track_started: True</b></p></summary><p dir="auto"></p>
<p dir="auto">
</p><div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content=""><pre class="notranslate"><code class="notranslate"></code></pre></div>
<p dir="auto"></p>
</details>
<h1 dir="auto">Steps to Reproduce</h1>
<h2 dir="auto">Required Dependencies</h2>

<ul dir="auto">
<li><strong>Minimal Python Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Celery Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Kombu Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Broker Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Result Backend Version</strong>: N/A or Unknown</li>
<li><strong>Minimal OS and/or Kernel Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Broker Client Version</strong>: N/A or Unknown</li>
<li><strong>Minimal Result Backend Client Version</strong>: N/A or Unknown</li>
</ul>
<h3 dir="auto">Python Packages</h3>

<details>
<summary><b><code class="notranslate">pip freeze</code> Output:</b></summary>
<p dir="auto">
</p><div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content=""><pre class="notranslate"><code class="notranslate"></code></pre></div>
<p dir="auto"></p>
</details>
<h3 dir="auto">Problem Description</h3>
<p dir="auto">When I was passing files immutiable dict object by calling a .delay() method, celery is throwing exception,</p>
<div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="[2019-07-19 10:58:48,420: CRITICAL/MainProcess] Can't decode message body: DecodeError(RecursionError('maximum recursion depth exceeded while calling a Python object',),) [type:'application/x-python-serialize' encoding:'binary' headers:{'lang': 'py', 'task': 'srm_rest_email.email.views.send_async_email', 'id': 'a6891a6e-e428-460b-bb98-940df5f430b2', 'shadow': None, 'eta': None, 'expires': None, 'group': None, 'retries': 0, 'timelimit': [None, None], 'root_id': 'a6891a6e-e428-460b-bb98-940df5f430b2', 'parent_id': None, 'argsrepr': &quot;({'file': &lt;FileStorage: '2019-05-07.png' ('image/png')&gt;}, {'exp': 1563589252, 'iat': 1563546052, 'sub': 'HTTPie/0.9.9', 'jti': '06df3341-c1cc-49ce-a7a8-d4a4983469ad', 'client_id': 'test_client', 'company_id': 1, 'operator_id': 'SC'})&quot;, 'kwargsrepr': '{}', 'origin': 'gen4932@achavhan-ThinkPad-X1-Carbon-6th'}]

body: b'\x80\x02cwerkzeug.datastructures\nImmutableMultiDict\nq\x00]q\x01X\x04\x00\x00\x00fileq\x02cwerkzeug.datastructures\nFileStorage\nq\x03)\x81q\x04c_codecs\nencode\nq\x05XH\x9f\x00\x00\xc2\x89PNG\r\n\x1a\n\x00\x00\x00\rIHDR\x00\x00\x03h\x00\x00\x01\x05\x08\x02\x00\x00\x00\x19\xc2\x81S\xc3\x87\x00\x00\x00\x03sBIT\x08\x08\x08\xc3\x9b\xc3\xa1O\xc3\xa0\x00\x00\x00_zTXtRaw profile type APP1\x00\x00\x08\xc2\x99\xc3\xa3JO\xc3\x8dK-\xc3\x8aLV((\xc3\x8aO\xc3\x8b\xc3\x8cI\xc3\xa5R\x00\x03c\x13.\x13K\x13K\xc2\xa3D\x03\x03\x03\x0b\x03\x0804006\x04\xc2\x92F@\xc2\xb69T(\xc3\x91\x00\x05\xc2\x98\xc2\x98\xc2\x9b\xc2\xa5\x01\xc2\xa1\xc2\xb9Y\xc2\xb2\xc2\x99)\xc2\x88\xc3\x8f\x05\x00O\xc2\xba\x15h\x1b-\xc3\x98\xc2\x8c\x00\x00... (41213b)
Traceback (most recent call last):
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 50, in _reraise_errors
    yield
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 263, in loads
    return decode(data)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 337, in unpickle
    return pickle_loads(str_to_bytes(s))
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 59, in pickle_loads
    return load(BytesIO(s))
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py&quot;, line 2821, in __getattr__
    return getattr(self.stream, name)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py&quot;, line 2821, in __getattr__
    return getattr(self.stream, name)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py&quot;, line 2821, in __getattr__
    return getattr(self.stream, name)
  [Previous line repeated 314 more times]
RecursionError: maximum recursion depth exceeded while calling a Python object

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/celery/worker/consumer/consumer.py&quot;, line 568, in on_task_received
    callbacks,
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/celery/worker/strategy.py&quot;, line 137, in task_message_handler
    if body is None and 'args' not in message.payload:
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/message.py&quot;, line 208, in payload
    return self._decoded_cache if self._decoded_cache else self.decode()
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/message.py&quot;, line 193, in decode
    self._decoded_cache = self._decode()
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/message.py&quot;, line 198, in _decode
    self.content_encoding, accept=self.accept)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 263, in loads
    return decode(data)
  File &quot;/usr/local/lib/python3.6/contextlib.py&quot;, line 99, in __exit__
    self.gen.throw(type, value, traceback)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 54, in _reraise_errors
    reraise(wrapper, wrapper(exc), sys.exc_info()[2])
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/vine/five.py&quot;, line 194, in reraise
    raise value.with_traceback(tb)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 50, in _reraise_errors
    yield
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 263, in loads
    return decode(data)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 337, in unpickle
    return pickle_loads(str_to_bytes(s))
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py&quot;, line 59, in pickle_loads
    return load(BytesIO(s))
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py&quot;, line 2821, in __getattr__
    return getattr(self.stream, name)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py&quot;, line 2821, in __getattr__
    return getattr(self.stream, name)
  File &quot;/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py&quot;, line 2821, in __getattr__
    return getattr(self.stream, name)
  [Previous line repeated 314 more times]
kombu.exceptions.DecodeError: maximum recursion depth exceeded while calling a Python object"><pre class="notranslate"><code class="notranslate">[2019-07-19 10:58:48,420: CRITICAL/MainProcess] Can't decode message body: DecodeError(RecursionError('maximum recursion depth exceeded while calling a Python object',),) [type:'application/x-python-serialize' encoding:'binary' headers:{'lang': 'py', 'task': 'srm_rest_email.email.views.send_async_email', 'id': 'a6891a6e-e428-460b-bb98-940df5f430b2', 'shadow': None, 'eta': None, 'expires': None, 'group': None, 'retries': 0, 'timelimit': [None, None], 'root_id': 'a6891a6e-e428-460b-bb98-940df5f430b2', 'parent_id': None, 'argsrepr': "({'file': &lt;FileStorage: '2019-05-07.png' ('image/png')&gt;}, {'exp': 1563589252, 'iat': 1563546052, 'sub': 'HTTPie/0.9.9', 'jti': '06df3341-c1cc-49ce-a7a8-d4a4983469ad', 'client_id': 'test_client', 'company_id': 1, 'operator_id': 'SC'})", 'kwargsrepr': '{}', 'origin': 'gen4932@achavhan-ThinkPad-X1-Carbon-6th'}]

body: b'\x80\x02cwerkzeug.datastructures\nImmutableMultiDict\nq\x00]q\x01X\x04\x00\x00\x00fileq\x02cwerkzeug.datastructures\nFileStorage\nq\x03)\x81q\x04c_codecs\nencode\nq\x05XH\x9f\x00\x00\xc2\x89PNG\r\n\x1a\n\x00\x00\x00\rIHDR\x00\x00\x03h\x00\x00\x01\x05\x08\x02\x00\x00\x00\x19\xc2\x81S\xc3\x87\x00\x00\x00\x03sBIT\x08\x08\x08\xc3\x9b\xc3\xa1O\xc3\xa0\x00\x00\x00_zTXtRaw profile type APP1\x00\x00\x08\xc2\x99\xc3\xa3JO\xc3\x8dK-\xc3\x8aLV((\xc3\x8aO\xc3\x8b\xc3\x8cI\xc3\xa5R\x00\x03c\x13.\x13K\x13K\xc2\xa3D\x03\x03\x03\x0b\x03\x0804006\x04\xc2\x92F@\xc2\xb69T(\xc3\x91\x00\x05\xc2\x98\xc2\x98\xc2\x9b\xc2\xa5\x01\xc2\xa1\xc2\xb9Y\xc2\xb2\xc2\x99)\xc2\x88\xc3\x8f\x05\x00O\xc2\xba\x15h\x1b-\xc3\x98\xc2\x8c\x00\x00... (41213b)
Traceback (most recent call last):
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 50, in _reraise_errors
    yield
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 263, in loads
    return decode(data)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 337, in unpickle
    return pickle_loads(str_to_bytes(s))
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 59, in pickle_loads
    return load(BytesIO(s))
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py", line 2821, in __getattr__
    return getattr(self.stream, name)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py", line 2821, in __getattr__
    return getattr(self.stream, name)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py", line 2821, in __getattr__
    return getattr(self.stream, name)
  [Previous line repeated 314 more times]
RecursionError: maximum recursion depth exceeded while calling a Python object

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/celery/worker/consumer/consumer.py", line 568, in on_task_received
    callbacks,
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/celery/worker/strategy.py", line 137, in task_message_handler
    if body is None and 'args' not in message.payload:
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/message.py", line 208, in payload
    return self._decoded_cache if self._decoded_cache else self.decode()
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/message.py", line 193, in decode
    self._decoded_cache = self._decode()
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/message.py", line 198, in _decode
    self.content_encoding, accept=self.accept)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 263, in loads
    return decode(data)
  File "/usr/local/lib/python3.6/contextlib.py", line 99, in __exit__
    self.gen.throw(type, value, traceback)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 54, in _reraise_errors
    reraise(wrapper, wrapper(exc), sys.exc_info()[2])
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/vine/five.py", line 194, in reraise
    raise value.with_traceback(tb)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 50, in _reraise_errors
    yield
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 263, in loads
    return decode(data)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 337, in unpickle
    return pickle_loads(str_to_bytes(s))
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/kombu/serialization.py", line 59, in pickle_loads
    return load(BytesIO(s))
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py", line 2821, in __getattr__
    return getattr(self.stream, name)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py", line 2821, in __getattr__
    return getattr(self.stream, name)
  File "/home/achavhan/srm_rest_email/env/lib/python3.6/site-packages/werkzeug/datastructures.py", line 2821, in __getattr__
    return getattr(self.stream, name)
  [Previous line repeated 314 more times]
kombu.exceptions.DecodeError: maximum recursion depth exceeded while calling a Python object
</code></pre></div>