From db3f4fe29f80c967a2c3d557a65cd42c3d741451 Mon Sep 17 00:00:00 2001 From: Raphael Date: Sat, 31 Aug 2024 10:19:41 +0200 Subject: [PATCH 1/2] fix: added missing flow id field --- proto/internal/flow.proto | 1 + 1 file changed, 1 insertion(+) diff --git a/proto/internal/flow.proto b/proto/internal/flow.proto index 024c2be..2864a18 100644 --- a/proto/internal/flow.proto +++ b/proto/internal/flow.proto @@ -8,6 +8,7 @@ import "node.proto"; import "flow_definition.proto"; message Flow { + int64 flow_id = 1; Node start_node = 2; FlowDefinition definition = 3; } From dbbc4bc304f5676efad2b08c78dfa7ec5b9a50c9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Raphael=20G=C3=B6tz?= <52959657+raphael-goetz@users.noreply.github.com> Date: Sat, 31 Aug 2024 10:59:01 +0200 Subject: [PATCH 2/2] Update flow.proto --- proto/internal/flow.proto | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/proto/internal/flow.proto b/proto/internal/flow.proto index 2864a18..708d906 100644 --- a/proto/internal/flow.proto +++ b/proto/internal/flow.proto @@ -24,8 +24,9 @@ message FlowLogonRequest { //Sagittarius sends flow to be updated message FlowResponse { - Flow updated_flow = 1; - FlowCommandType type = 2; + optional Flow updated_flow = 1; + optional int64 deleted_flow_id = 2; + FlowCommandType type = 3; } //All ids of flows that Aquila holds @@ -44,4 +45,4 @@ message FlowGetResponse { service FlowService { rpc Get (FlowGetRequest) returns (FlowGetResponse) {} rpc Update (FlowLogonRequest) returns (stream FlowResponse) {} -} \ No newline at end of file +}