celery - Set number of workers for each task in schedule -
i have 4 scheduled task in celery executes every n seconds. now, application logic provides 1 worker each task ( write-reads data db, , parallel execution not allowed).
but can set 1 worker tasks using celeryd_concurrency = 1
how can set single worker each task? thanks
i think mean don't want 4 tasks run in parallel? if case should use 'chain' of subtasks, see:
http://docs.celeryproject.org/en/latest/userguide/canvas.html#chains
just add tasks chain | operator, , execute delay() or async_delay(). in way, next task start after previous 1 has completed. , 1 worker pool assigned each task (which can same worker or different one).
Comments
Post a Comment