Skip to content

Commit 46d4585

Browse files
authored
fix body bytes encoding in curl.py (#2322)
1 parent 8723026 commit 46d4585

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

kombu/asynchronous/http/curl.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,11 @@ def _setup_request(self, curl, request, buffer, headers, _pycurl=pycurl):
252252
setopt(meth, True)
253253

254254
if request.method in ('POST', 'PUT'):
255-
body = request.body.encode('utf-8') if request.body else b''
255+
if not request.body:
256+
body = b''
257+
else:
258+
body = request.body if isinstance(request.body, bytes) else request.body.encode('utf-8')
259+
256260
reqbuffer = BytesIO(body)
257261
setopt(_pycurl.READFUNCTION, reqbuffer.read)
258262
if request.method == 'POST':

0 commit comments

Comments
 (0)