¿Puedo utilizar una primitiva de apio Group como tarea paraguas en un mapa/reducir el flujo de trabajo?Tarea del grupo de apio para usar en un flujo de trabajo de mapa/reducir
O más específico: ¿Pueden las subtareas en un grupo ejecutarse en varios trabajadores en múltiples servidores ?
A partir de los documentos:
However, if you call apply_async on the group it will send a special
grouping task, so that the action of calling the tasks happens in a worker
instead of the current process
Eso parece implicar todas las tareas se envíe a un trabajador ...
Antes 3.0 (y sigue siendo) uno podría disparar las subtareas en un taskset cuales se ejecutaría en múltiples servidores. El problema es determinar si todas las tareas han terminado de ejecutarse. Eso normalmente se hace al sondear todas las subtareas que no son realmente elegantes. Me pregunto si la primitiva de grupo se puede utilizar para mitigar este problema.
distribuye las tareas perfectamente bien con un comando regular de 'grupo' al menos en apio 3.1, parece que la declaración anterior se eliminó de los documentos – Grozz