Fixes pack(str) -> pack(bytes). Closes celery#3674

hilmar8 · Dec 13, 2016 · 0204d00 · 0204d00
1 parent a223318
commit 0204d00
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/celery/concurrency/asynpool.py b/celery/concurrency/asynpool.py
@@ -812,7 +812,7 @@ def send_job(tup):
             # inqueues are writable.
             body = dumps(tup, protocol=protocol)
             body_size = len(body)
-            header = pack('>I', body_size)
+            header = pack(b'>I', body_size)
             # index 1,0 is the job ID.
             job = get_job(tup[1][0])
             job._payload = buf_t(header), buf_t(body), body_size
@@ -1252,7 +1252,7 @@ def _create_payload(self, type_, args,
                         protocol=HIGHEST_PROTOCOL):
         body = dumps((type_, args), protocol=protocol)
         size = len(body)
-        header = pack('>I', size)
+        header = pack(b'>I', size)
         return header, body, size
 
     @classmethod