Skip to content

Commit

Permalink
remove tick sleep
Browse files Browse the repository at this point in the history
  • Loading branch information
Amogh-Bharadwaj committed Dec 8, 2023
1 parent 8666290 commit 15acf64
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion flow/activities/flowable.go
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 15acf64

Please sign in to comment.