Python-RQ не может запустить пример кода, упомянутый в примере

Я не могу запустить пример кода, упомянутого в документации по rq здесь

from rq import Queue
from redis import Redis
from test import count_words_at_url
import time
# Tell RQ what Redis connection to use
redis_conn = Redis()
q = Queue(connection=redis_conn)  # no args implies the default queue
#
## Delay execution of count_words_at_url('http://nvie.com')
job = q.enqueue(count_words_at_url,  'http://nvie.com')
job.perform
print job
print job.result   # => None
#
## Now, wait a while, until the worker is finished
time.sleep(2)
print job.result   # => 889

И мой вывод

<Job e8e7a5c7-f892-4931-86c8-6362e6e76464: test.count_words_at_url('http://nvie.com')>
None
None

Это то, что я получаю на своем rq-dashboard

Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/rq/worker.py", line 771, in perform_job
    rv = job.perform()
  File "/usr/local/lib/python2.7/dist-packages/rq/job.py", line 558, in perform
    self._result = self._execute()
  File "/usr/local/lib/python2.7/dist-packages/rq/job.py", line 564, in _execute
    return self.func(*self.args, **self.kwargs)
  File "/usr/local/lib/python2.7/dist-packages/rq/job.py", line 205, in func
    return import_attribute(self.func_name)
  File "/usr/local/lib/python2.7/dist-packages/rq/utils.py", line 153, in import_attribute
    return getattr(module, attribute)
AttributeError: 'module' object has no attribute 'count_words_at_url'

Когда я обхожу работника, говоря async=False тогда работает нормально.

Что мне здесь не хватает?

0 ответов

Другие вопросы по тегам