芹菜和弦回调一直始终启动

Question

更新完成后，我正在尝试使用和弦启动报告更新。

@shared_task(autoretry_for=(Exception,), retry_backoff=True, retry_kwargs {'max_retries': 5})
def upload(df: pd.DataFrame, **kwargs):
    ed = EntityDataPoint(df, **kwargs)
    uploadtasks, source, subtype = ed.upload_database()
    chord(uploadtasks)(final_report.si(logger=ed.logger, 
                                       source=source, 
                                       subtype=subtype,
                                       index=ed.index))

上loadTask为：

    g = group(unwrap_upload_bulk.s(obj = self, data = self.data.iloc[i:i+chunk_size]) 
                                     for i in range(0, len(self.data), chunk_size))

当和弦的标题具有2个以上的元素时，前两个子任务成功，并且没有启动组中的其余任务，而没有任何错误，没有任何错误，也没有任何信息芹菜工人记录。在检查工人之后，安排了芹菜检查活动，排队似乎没有任何等待任务。

如果标题（组）具有2个或更少的元素，则没有问题，组任务完成，调用回调。

它似乎不取决于元素的大小（如果组中的每个子任务都发送100行，我们仍然对1000行具有相同的行为）。

如果我只是启动组任务，而没有和弦和回调，那么任务成功而没有任何错误。

我尝试为和弦使用不同的语法，但似乎并没有改变任何内容。

我尝试使用group.link功能来查看会发生什么，并且在执行此操作时，该组似乎完成了，但是在所有组任务完成后，回调不会发生，因为它并不是为此设计的，正如我从我所理解的那样文档，所以这不是我想要的行为。

我使用的是REDIS 7.0.0经纪人的芹菜5.2.3和django 3.2.13带PSQL的后端，带有Python 3.9。 一切都在单独的Docker容器上运行。

Answer 1

看来直接将小组作为和弦的标题正在创建问题。它可能是将组中的第一个任务用作标题，而将第二个任务用作回调（尽管我不明白为什么这不会导致这些任务的参数引起某些错误）。
而不是返回：

group(unwrap_upload_bulk.s(obj = self, data = self.data.iloc[i:i+chunk_size]) 
                                     for i in range(0, len(self.data), chunk_size))

我现在返回：

[unwrap_upload_bulk.s(obj = self, data = self.data.iloc[i:i+chunk_size]) 
                                     for i in range(0, len(self.data), chunk_size)]

它正常工作。