Skip to content

Commit

Permalink
Fix log message
Browse files Browse the repository at this point in the history
Signed-off-by: Alan Kutniewski <kutniewski@google.com>
  • Loading branch information
alan-kut committed Jul 25, 2024
1 parent 18952d8 commit 75c2ce9
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion core/pkg/sync/blob/blob_sync.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ func (hs *Sync) IsReady() bool {
}

func (hs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
hs.Logger.Info(fmt.Sprintf("starting sync from %s/%s with interval %d", hs.Bucket, hs.Object, hs.Interval))
hs.Logger.Info(fmt.Sprintf("starting sync from %s/%s with interval %ds", hs.Bucket, hs.Object, hs.Interval))
_ = hs.Cron.AddFunc(fmt.Sprintf("*/%d * * * *", hs.Interval), func() {
err := hs.sync(ctx, dataSync, false)
if err != nil {
Expand Down Expand Up @@ -88,6 +88,9 @@ func (hs *Sync) sync(ctx context.Context, dataSync chan<- sync.DataSync, skipChe
hs.Logger.Debug("configuration hasn't changed, skipping fetching full object")
return nil
}
if hs.lastUpdated.After(updated) {
hs.Logger.Warn("configuration changed but the modification time decreased instead of increasing")
}
}
msg, err := hs.fetchObject(ctx, bucket)
if err != nil {
Expand Down

0 comments on commit 75c2ce9

Please sign in to comment.