1

我正在使用 django-celery 并进行了设置,因此我可以从交互式 shell 调用任务,任务完成(如 celery 日志所示),我在 celeryd 输出中看到了结果。

但是,我似乎无法在启动任务的 shell 中获得任务的结果:

>>> from mymodule.tasks import testTask
>>> res = testTask.delay()
>>> testTask.ready()
False

@task
def testTask():
logger.info('LOGGER: start task')
time.sleep(10)
logger.info('LOGGER: stop task')
return 5 

我假设这是由于我有时会遇到以下错误:

TxIsolationWarning: Polling results with transaction isolation level repeatable-read within the same transaction may give outdated results. Be sure to commit the transaction for each poll iteration.

我的问题,我如何提交交易,这是在哪里完成的?另外,这里有什么问题?Celery 试图在 Django 锁定表时从 mysql 访问信息?

提前致谢,

4

1 回答 1

2

如果您使用 MySQL 作为代理,请检查事务隔离级别。

http://docs.celeryproject.org/en/latest/faq.html#mysql-is-throwing-deadlock-errors-what-c​​an-i-do

于 2013-07-10T07:41:22.503 回答