enhanced admin ormq panel fix and schedules with broker_name

Koed00 · Feb 6, 2021 · 1d6d996 · 1d6d996
1 parent 10df835
commit 1d6d996
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/django_q/admin.py b/django_q/admin.py
@@ -100,8 +100,7 @@ def has_add_permission(self, request):
         """Don't allow adds."""
         return False
 
-    list_filter = ("key", "func")
-    search_fields = ("name", "func")
+    list_filter = ("key",)
 
 
 admin.site.register(Schedule, ScheduleAdmin)

diff --git a/django_q/cluster.py b/django_q/cluster.py
@@ -633,7 +633,12 @@ def scheduler(broker: Broker = None):
                     )
                     s.repeats += -1
                 # send it to the cluster
-                q_options["broker"] = broker
+                scheduled_broker = broker
+                try:
+                    scheduled_broker = get_broker(q_options["broker_name"])
+                except: # invalid broker_name or non existing broker with broker_name
+                    pass
+                q_options["broker"] = scheduled_broker
                 q_options["group"] = q_options.get("group", s.name or s.id)
                 kwargs["q_options"] = q_options
                 s.task = django_q.tasks.async_task(s.func, *args, **kwargs)