minor fixes pt.1

PeerDB-io · Jan 3, 2024 · e6c03b0 · e6c03b0
1 parent ecc91d8
commit e6c03b0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/nexus/flow-rs/src/grpc.rs b/nexus/flow-rs/src/grpc.rs
@@ -113,6 +113,7 @@ impl FlowGrpcClient {
             requested_flow_state: state.into(),
             source_peer: Some(workflow_details.source_peer),
             destination_peer: Some(workflow_details.destination_peer),
+            flow_state_update: None
         };
         let response = self.client.flow_state_change(state_change_req).await?;
         let state_change_response = response.into_inner();

diff --git a/protos/flow.proto b/protos/flow.proto
@@ -423,7 +423,7 @@ enum FlowStatus {
 message CDCFlowStateUpdate {
 }
 
-message QRepFlowStateUpdate  {
+message QRepFlowStateUpdate {
 }
 
 message FlowStateUpdate {

diff --git a/protos/route.proto b/protos/route.proto
@@ -188,7 +188,7 @@ message FlowStateChangeRequest {
   peerdb_peers.Peer source_peer = 3;
   peerdb_peers.Peer destination_peer = 4;
   // only can be sent in certain situations
-  peerdb_flow.FlowStateUpdate flow_state_update = 5;
+  optional peerdb_flow.FlowStateUpdate flow_state_update = 5;
 }
 
 message FlowStateChangeResponse {