Переглянути джерело

Merge branch '3.0'

Conflicts:
	Changelog
	README.rst
	celery/__init__.py
	docs/includes/introduction.txt
Ask Solem 12 роки тому
батько
коміт
16eeae0b30
2 змінених файлів з 15 додано та 0 видалено
  1. 12 0
      Changelog
  2. 3 0
      celery/worker/job.py

+ 12 - 0
Changelog

@@ -5,6 +5,8 @@
 .. contents::
     :local:
 
+.. _version-3.1.0:
+
 3.1.0
 =====
 :state: DEVEL
@@ -13,6 +15,16 @@
 - `Task.apply_async` now supports timeout and soft_timeout arguments (Issue #802)
 - `App.control.Inspect.conf` can be used for inspecting worker configuration
 
+.. _version-3.0.3:
+
+3.0.3
+=====
+:release-date: 2012-07-20 09:17 P.M BST
+:by: Ask Solem
+
+- amqplib passes the channel object as part of the delivery_info
+  and it's not pickleable, so we now remove it.
+
 .. _version-3.0.2:
 
 3.0.2

+ 3 - 0
celery/worker/job.py

@@ -127,6 +127,9 @@ class Request(object):
             self.expires = None
 
         self.delivery_info = delivery_info or {}
+        # amqplib transport adds the channel here for some reason, so need
+        # to remove it.
+        self.delivery_info.pop('channel', None)
         self.request_dict = body
 
     @classmethod