Python Reddis Queue ValueError:Функциите от модула __main__ не могат да бъдат обработени от работници

Разбийте предоставения код на два файла:count_words.py :

import requests

def count_words_at_url(url):
    resp = requests.get(url)
    return len(resp.text.split())

и main.py (където ще импортирате необходимата функция):

from rq import Connection, Queue
from redis import Redis
from count_words import count_words_at_url # added import!
redis_conn = Redis()
q = Queue(connection=redis_conn)
job = q.enqueue(count_words_at_url, 'http://nvie.com')
print job

Винаги разделям задачите от логиката, изпълняваща тези задачи към различни файлове. Просто е по-добра организация. Също така имайте предвид, че можете да дефинирате клас задачи и да импортирате/планирате задачи от този клас вместо (прекалено опростената) структура, която предлагам по-горе. Това трябва да ви подтикне.. Вижте също тук, за да потвърдите, че не сте първият, който се бори с този пример. RQ е страхотен след като се овладеете.