Catch non-existent trigger

vikingco · May 23, 2018 · 006f60b · 006f60b
1 parent e5f59c6
commit 006f60b
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/djtriggers/tasks.py b/djtriggers/tasks.py
@@ -3,6 +3,8 @@
 
 from django.apps import apps
 
+from .models import Trigger
+
 
 logger = get_task_logger(__name__)
 
@@ -21,4 +23,7 @@ def clean_triggers():
 
 @shared_task
 def process_trigger(trigger_id, trigger_app_label, trigger_class, *args, **kwargs):
-    apps.get_model(trigger_app_label, trigger_class).objects.get(id=trigger_id).process(*args, **kwargs)
+    try:
+        apps.get_model(trigger_app_label, trigger_class).objects.get(id=trigger_id).process(*args, **kwargs)
+    except Trigger.DoesNotExist:
+        pass