Цепочка вакансий в сельдерее - мимолетные результаты - PullRequest
0 голосов
/ 07 мая 2018

Я пытаюсь использовать работу цепь в сельдерее (4.10).

У меня есть следующие три функции, используемые в цепочке заданий.

parameter_1 = "This is a parameter"
parameter_2 = "This is another parameter"

def validate_user(user_credentials)
    ...
    return validate_result

def register_user(validate_result, parameter_1)
    ...
    return registration_result

def update_user(validate_result, registration_result, parameter_2)
    ...
    return update_result

result = chain(
    validate_user.s(user_credentials),
    register_user.s(parameter_1), # validate_result will be available in **kwargs
    update_user.s(parameter_2) # registration_result will be available in **kwargs, but I can not access validate_result
    ).apply_async()

Может кто-нибудь указать, что я делаю неправильно, почему я не могу передать validate_result на update_user в цепочке вакансий.

Или это неправильная модель, и я должен использовать что-то вроде Классы задач для случая, подобного этому?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...