芹菜任务正在后续任务中分配本地实例属性

Question

我有一个任务，每次处理新任务时都会创建一个任务历史记录。我在task函数的开头实例化了一个新的TaskHistory实例。由于某些原因，在上一个任务中分配的TaskHistory类属性将在后续任务中分配给TaskHistory类属性。例如，如果任务成功，我将分配：

 task_history.meta['success'] = 'Successfully processed {} rows '.format(row_count)'

在随后的任务中，它可能会失败，我分配：

task_history.meta['error'] = 'Processed {} rows '.format(row_count) + str(e)

后面的任务应该只分配meta['error']，但是它也在分配前面的meta['success']值，即使任务的历史记录被重新实例化。你知道吗

下面是调用任务的代码：

args = [file_ids]
kwargs = {'requester': request.user.profile}
csv_import.apply_async(args=args, kwargs=kwargs)

任务函数如下：

@task
def csv_import(file_ids, requester=None):
    task_history = TaskHistory()
    task_history.requester = requester
    task_history.status = 'pending'
    task_history.started = timezone.now()
    task_history.save()
    row_count = 0
    try:

       //main logic goes here

       task_history.status = 'completed'
       task_history.completed = now()
       task_history.meta['success'] = 'Successfully processed {} rows '.format(row_count)
       task_history.save()
    except Exception as e:
        task_history.status = 'failed'
        task_history.completed = timezone.now()
        task_history.meta['error'] = 'Processed {} rows '.format(row_count) + str(e)
        task_history.save()
        raise Exception

Answer 1

最后，这与芹菜无关，而是与我在模型中为元字段设置默认值的方式有关。meta字段是一个JSONfield（），我将默认值设置为default={}，这将创建一个可变实例，并在JSONfield的所有实例之间共享。我通过将其设置为可调用的dict来解决这个问题。新字段现在显示如下：

meta = JSONField(default=dict)

更多关于这个的信息可以在这里找到https://docs.djangoproject.com/es/1.9/ref/contrib/postgres/fields/#jsonfield。这是适用于所有模型默认值的相同标准。你知道吗