Skip to content

Commit 2598230

Browse files
authored
feat(plugins/aws): check for dupe instance id (Netflix#5174)
1 parent 77de8e3 commit 2598230

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/dispatch/plugins/dispatch_aws/plugin.py

+8
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,14 @@ def consume(self, db_session: Session, project: Project) -> None:
7777
)
7878
continue
7979

80+
# if the signal has an existing uuid we check if it already exists
81+
if signal_instance_in.raw and signal_instance_in.raw.get("id"):
82+
if signal_service.get_signal_instance(db_session=db_session, signal_instance_id=signal_instance_in.raw["id"]):
83+
log.info(
84+
f"Received signal instance that already exists in the database, skipping creation: {signal_instance_in.raw['id']}"
85+
)
86+
continue
87+
8088
try:
8189
with db_session.begin_nested():
8290
signal_instance = signal_service.create_signal_instance(

0 commit comments

Comments
 (0)