Hey folks,
I have a chord where the inside group returns a big iterable (list). I'm trying to split this iterable to execute the callback in some chunks (something like task.chunks)
I have something like this:
celery.chord(
gropu_task.s(iterable), callback_task.s(big_iterable)
)
------------------------------------------
I already tryed this:
celery.chord(
gropu_task.s(iterable), callback_task.s(big_iterable)
)
But, it does not work :/
any help would be appreciated
thanks!