python - 動的に定義されたコードを持つセロリ チェーン

Question

署名のリストから和音を生成しようとしています。このリストの長さは、チェーンの実行開始時には不明です。例えば。の出力はtask_clenth のリストですn。このリストは、並行して実行される同じ長さのセロリ署名のリストを生成する必要があります。前のタスクの結果には部分的な署名でしかアクセスできない.s()ため、チェーン内でこの署名のグループを動的に定義するにはどうすればよいでしょうか?

例えば。これからどうすればいいですか：

@task
def task_d(kwargs):
    return [task_e.si(i) for i in random.sample(range(10, 30), 5)]

ctask = chain(
    task_a.si(**kwargs),
    task_b.si(**kwargs),
    task_c.si(**kwargs),
    chord(
            [
                task_e.si(**kwargs),
                task_e.si(**kwargs),
                task_e.si(**kwargs),
            ],
            my_callback.si(**kwargs),
        ),
    ),

...ここまで

ctask = chain(
    task_a.si(**kwargs),
    task_b.si(**kwargs),
    task_c.si(**kwargs),
    chord(
            [task_d.s(**kwargs)],     <<<<<< ?
            my_callback.si(**kwargs),
        ),
    ),