diff --git a/flow/activities/slot.go b/flow/activities/slot.go index cf1375b4e4..117dbecea3 100644 --- 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())