Функция Django-Execute после завершения работы с сельдерей

Question

Я использую Сельдерей с Ткань. Моя сельдерей задача копирует файл на моей локальной машине Как это:

@app.task 
def copytolocal(): 
get('/home/remote/file.txt','/home/local/') # Copying to local dir 

Когда в представлении я пытаюсь открыть и прочитать файл я получаю IOError, потому что задача еще не завершена

taskfile.app.send_task('taskfile.copytolocal',[]) # Sending task to queue 
open('/home/local/file.txt') #IOError because task isnt completed yet   

Если я использую что-то вроде asyncresult.ready(), то он возвращается False на казнь исполнения. Есть ли способ реализовать что-то вроде обратного вызова или иначе и как это сделать.

Answer 1

Самый простой способ будет сделать

while not asyncresult.ready(): 
    time.sleep(1) 

# Now the file is downloaded 

И если вы хотите немного лучше вы можете использовать callbacks где link это задача, которая должна быть выполнена, когда регулярная задача выполнена.

download_file.apply_async(path, link=write_to_db.subtask(path))