Я пытаюсь использовать работу цепь в сельдерее (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
в цепочке вакансий.
Или это неправильная модель, и я должен использовать что-то вроде Классы задач для случая, подобного этому?