Make it a non-fatal error if we are unable to get slot information (#891

)
PeerDB-io · Dec 23, 2023 · e20a2e5 · e20a2e5
1 parent be6b5c2
commit e20a2e5
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/flow/activities/slot.go b/flow/activities/slot.go
@@ -23,6 +23,11 @@ func (a *FlowableActivity) handleSlotInfo(
 		return err
 	}
 
+	if slotInfo == nil || len(slotInfo) == 0 {
+		slog.WarnContext(ctx, "warning: unable to get slot info", slog.Any("slotName", slotName))
+		return nil
+	}
+
 	deploymentUIDPrefix := ""
 	if peerdbenv.PeerDBDeploymentUID() != "" {
 		deploymentUIDPrefix = fmt.Sprintf("[%s] ", peerdbenv.PeerDBDeploymentUID())