Celery Chord with a big callback | task.chunks

76 views
Skip to first unread message

Miguel Angel Galicia

unread,
Jul 2, 2020, 6:11:32 PM7/2/20
to celery-users
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!



Reply all
Reply to author
Forward
0 new messages