Celery выполняет функцию анализа файла до завершения загрузки файла.Я использую Django + сельдерей

Question

У меня есть задача сельдерея, которая требует скачать файл с удаленного сервера и затем проанализировать его.Пока я пытался сделать это сначала с помощью обычной функции download (), а затем parse ().Но celery выполняет функцию синтаксического анализа еще до загрузки, что вызывает ошибку. Есть ли способ синхронизировать эти два выполнения?

file.download()   #calling function to download file
file.parse()      #calling function to parse the file
#followed by more code

Answer 1

это способ цепного метода.

chanin = downdload.s()| parse.s()
chain.apply_async()