Ich möchte bei meinen Selleriearbeitern Prioritäten setzen. Ich kann dies tun, indem ich verschiedene Warteschlangen für Aufgaben mit hoher Priorität und für Aufgaben mit niedriger Priorität erstelle. Aber ich muss Broadcast-Aufgaben auch an alle Arbeiter mit Broadcast-Warteschlange senden und es funktioniert nicht. Hier ist die Datei tasks.py:
%Vor%Wenn ich Selleriearbeiter mit Befehl renne:
%Vor%Die Aufgabenpriorität funktioniert, Broadcastaufgaben werden jedoch nicht bestätigt.
Wenn ich Befehl ohne Warteschlangenargument ausfühle, funktioniert Broadcast, aber die Aufgabenpriorität nicht:
%Vor% Wie ich es verstehe passiert, weil Broadcast Queue einen eindeutigen Namen haben, wie bcast.0b5dbce0-9bcb-48a5-8554-cbb7f32a6703 für jeden Arbeiter.
Hat jemand einen guten Workaround? Vielen Dank im Voraus!