I want Celery canvas to support chunked task execution through a chunks(task, it, n, options) signature…
I want Celery canvas to support chunked task execution through a chunks(task, it, n, options) signature…: a task in MiMo-V2.6-RL-harbor-code: MiMo-V2.6-RL Code (Harbor) (Harbor dataset). The chunked signature should also be executable: add.chunks(zip(range(4), range(4)), 2)() should apply the…
The task
The chunked signature should also be executable: `add.chunks(zip(range(4), range(4)), 2)()` should apply the generated group immediately and return the group result, while `.apply_async(countdown=10)` should publish the generated group with the supplied execution options and route it using the underlying task name.…
Part of FineEnvs/MiMo-V2.6-RL-harbor-code.