Skip to content
This repository was archived by the owner on Aug 30, 2024. It is now read-only.

Commit c2ca1ea

Browse files
committed
Improve replace message
1 parent ba23ea5 commit c2ca1ea

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

internal/sync/eventcache.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ func (cache eventCache) Add(ev timedEvent) {
2929
}
3030
}
3131
if ok {
32-
log.Info("ignored duplicate event (%s replaced by %s)", lastEvent.Event(), ev.Event())
32+
log.Info("replaced %s with %s", lastEvent.Event(), ev.Event())
3333
}
3434
// Only let the latest event for a path have action.
3535
cache[ev.Path()] = ev

internal/sync/sync.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -272,7 +272,6 @@ func (s Sync) Run() error {
272272
if time.Since(eventGroup[0].CreatedAt) > maxEventDelay {
273273
return ErrRestartSync
274274
}
275-
276275
s.workEventGroup(eventGroup)
277276
eventGroup = eventGroup[:0]
278277
}

0 commit comments

Comments
 (0)