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
тогда работает нормально.
Что мне здесь не хватает?