diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go index 9d58ee9757..68ea12357e 100644 --- a/flow/activities/flowable.go +++ b/flow/activities/flowable.go @@ -195,7 +195,6 @@ func (a *FlowableActivity) recordSlotSizePeriodically( case <-ticker.C: err := a.handleSlotInfo(ctx, srcConn, slotName, peerName) if err != nil { - time.Sleep(30 * time.Second) return nil } case <-done: