On 03 Nov 2012, at 6:25 AM, Josh Beard wrote:
> That mostly fixed it! The tables are now in the MySQL database and I'm able
> to preview messages.
>
> Unfortunately, when attempting to 'release' or take any other action, such as
> delete or learn, I now get:
>
> [2012-11-02 22:20:32,836: INFO/MainProcess] Got task from broker:
> process-quarantine[288f34f9-a2b7-4536-b8e9-a0dd2ef3b1fe]
> [2012-11-02 22:20:32,837: DEBUG/MainProcess] TaskPool: Apply <function
> _fast_trace_task at 0x80a32bd70> (args:(u'process-quarantine',
> u'288f34f9-a2b7-4536-b8e9-a0dd2ef3b1fe', [{u'use_alt': False, u'salearn_as':
> u'spam', u'release': True, u'todelete': False, u'learn': False,
> u'altrecipients': u'', u'message_id': [u'1B34981D012.AEE0F']}], {},
> {u'retries': 0, 'is_eager': False, u'task': u'process-quarantine', 'group':
> None, u'eta': None, 'delivery_info': {'priority': None, 'routing_key':
> u'mx1bsd1', 'exchange': u'default'}, u'args': [{u'use_alt': False,
> u'salearn_as': u'spam', u'release': True, u'todelete': False, u'learn':
> False, u'altrecipients': u'', u'message_id': [u'1B34981D012.AEE0F']}],
> u'expires': None, u'callbacks': None, u'errbacks': None, 'hostname':
> 'celery.mx1bsd1', u'kwargs': {}, u'id':
> u'288f34f9-a2b7-4536-b8e9-a0dd2ef3b1fe', u'utc': True}) kwargs:{})
> [2012-11-02 22:20:32,839: INFO/PoolWorker-1]
> process-quarantine[288f34f9-a2b7-4536-b8e9-a0dd2ef3b1fe]: Bulk Processing 1
> quarantined messages
> [2012-11-02 22:20:32,865: DEBUG/MainProcess] Task accepted:
> process-quarantine[288f34f9-a2b7-4536-b8e9-a0dd2ef3b1fe] pid:76073
> [2012-11-02 22:20:32,867: ERROR/MainProcess] Task
> process-quarantine[288f34f9-a2b7-4536-b8e9-a0dd2ef3b1fe] raised exception:
> KeyError('task_id',)
> Traceback (most recent call last):
> File
> "/usr/local/lib/python2.7/site-packages/celery-3.0.11-py2.7.egg/celery/task/trace.py",
> line 224, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/usr/local/lib/python2.7/site-packages/celery-3.0.11-py2.7.egg/celery/task/trace.py",
> line 403, in __protected_call__
> return self.run(*args, **kwargs)
> File
> "/usr/local/lib/python2.7/site-packages/baruwa-1.1.2-py2.7.egg/baruwa/messages/tasks.py",
> line 152, in run
> self.update_state(kwargs["task_id"], "PROGRESS",
> KeyError: 'task_id'
Seems magic kwargs is broken in celery >= 3.0.6 [1] will investigate and fix
[1] http://docs.celeryproject.org/en/latest/changelog.html#version-3-0-6
--
www.baruwa.org
_______________________________________________
Keep Baruwa FREE - http://pledgie.com/campaigns/12056
