Commit ef9ff5ee authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

NBI Component - SSE Telemetry Connector: 

- Corrected database insert method
parent d45bdce1

src/nbi/service/sse_telemetry/database/Subscription.py

+1 −1
Original line number Diff line number Diff line
@@ -40,7 +40,7 @@ def set_subscription(db_engine: Engine, request: SSESubsciprionDict) -> None: 
    def callback(session: Session) -> bool:

        stmt = insert(SSESubscriptionModel).values([request])

        stmt = stmt.on_conflict_do_update(

            index_elements=[SSESubscriptionModel.id],

            index_elements=[SSESubscriptionModel.uuid],

            set_=dict(

                uuid=stmt.excluded.uuid,

                identifier=stmt.excluded.identifier,