Adds initial canary support

Netflix · Sep 11, 2023 · 394b567 · 394b567
1 parent 7b3ac8c
commit 394b567
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/dispatch/signal/flows.py b/src/dispatch/signal/flows.py
@@ -90,6 +90,10 @@ def signal_instance_create_flow(
             )
         return signal_instance
 
+    # limited support for canary signals, just store the instance and return
+    if signal_instance.canary:
+        return signal_instance
+
     if not signal_instance.signal.create_case:
         return signal_instance
 

diff --git a/src/dispatch/signal/models.py b/src/dispatch/signal/models.py
@@ -231,6 +231,7 @@ class SignalInstance(Base, TimeStampMixin, ProjectMixin):
     case_priority = relationship("CasePriority", backref="signal_instances")
     fingerprint = Column(String)
     filter_action = Column(String)
+    canary = Column(Boolean, default=False)
     raw = Column(JSONB)
     signal = relationship("Signal", backref="instances")
     signal_id = Column(Integer, ForeignKey("signal.id"))
@@ -301,6 +302,7 @@ class SignalBase(DispatchBase):
     case_type: Optional[CaseTypeRead]
     case_priority: Optional[CasePriorityRead]
     external_id: str
+    canary: Optional[bool] = False
     enabled: Optional[bool] = False
     external_url: Optional[str]
     create_case: Optional[bool] = True