Skip to content

Commit 0506880

Browse files
committed
deplay: use park instead of transit
1 parent 1680d77 commit 0506880

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

delay.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -203,11 +203,10 @@ func NewDelayer(e Engine, l *slog.Logger) (*Delayer, error) {
203203
ID: `flowstate.delayer.meta`,
204204
Rev: 0,
205205
}
206-
DisableRecovery(metaStateCtx)
207206
setDelayerMetaState(metaStateCtx, time.Unix(0, 0).UTC(), 0)
208207

209208
if err := d.e.Do(Commit(
210-
Transit(metaStateCtx, `na`),
209+
Park(metaStateCtx),
211210
)); IsErrRevMismatch(err) {
212211
return nil, fmt.Errorf("another process is already doing delaying; exiting (todo: implement standby mode)")
213212
} else if err != nil {
@@ -286,7 +285,7 @@ func (d *Delayer) maybeCommitMeta() {
286285

287286
nextMetaState := d.metaStateCtx.CopyTo(&StateCtx{})
288287
setDelayerMetaState(nextMetaState, d.commitSince, d.commitOffset)
289-
if err := d.e.Do(Commit(Transit(nextMetaState, `na`))); IsErrRevMismatch(err) {
288+
if err := d.e.Do(Commit(Park(nextMetaState))); IsErrRevMismatch(err) {
290289
d.l.Warn("another process is already doing delaying; exiting (todo: implement standby mode)")
291290
} else if err != nil {
292291
d.l.Error(fmt.Sprintf("commit meta state: %s", err))

0 commit comments

Comments
 (0)