Изменился ли идентификатор задачи сельдерея после перераспределения

Question

У меня есть модель Django с колонкой celery_task_id. Я использую RabbitMQ в качестве брокера. Существует функция сельдерея, называемая test_celery, которая принимает модельный объект в качестве параметра. Теперь у меня есть следующие строки кода, которые создают задачу сельдерея.

def create_celery_task(): 
    celery_task_id = test_celery.apply_async((model_obj,), eta='Future Datetime Object') 
    model_obj.celery_task_id = celery_task_id 
    model_obj.save() 
    ---- 
    ---- 

Теперь внутри функции сельдерея я проверки, если идентификатор задачи такой же, как из одной хранимой в БД или нет.

@app.task 
def test_celery(model_obj): 
    if model_obj.celery_task_id == test_celery.request.id: 
     ## Do something 

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

Возможно ли, что идентификатор задачи сельдерея изменится после перераспределения. Или есть другие причины.

Answer 1

Одна из рекомендаций - не передавать объекты базы данных/ORM в задачи Celery, поскольку они могут содержать устаревшие данные. Попробуйте переписать задачу как:

@app.task 
def test_celery(model_obj_id): 
    model_obj = YourModel.objects.get(id=model_obj_id) 
    if model_obj: 
     if model_obj.celery_task_id == test_celery.request.id: 
      ## Do something