Skip to content

Commit

Permalink
Hack watchable cache one again
Browse files Browse the repository at this point in the history
Signed-off-by: sashayakovtseva <[email protected]>
  • Loading branch information
sashayakovtseva committed Mar 18, 2024
1 parent d8e1fe5 commit b9ac9d9
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion internal/datastore/ydb/watch.go
Original file line number Diff line number Diff line change
Expand Up @@ -398,9 +398,12 @@ func (y *ydbDatastore) watch(
}
}

// WARNING! This is for test purpose only and only for namespace-aware schema watch!
// todo Fix this when 'resolved'-like messages are supported.
futureCheckpoint := revisions.NewForTime(changesRevision.Time().Add(time.Hour * 24))
if opts.Content&datastore.WatchCheckpoints == datastore.WatchCheckpoints {
if !sendChange(&datastore.RevisionChanges{
Revision: changesRevision,
Revision: futureCheckpoint,
IsCheckpoint: true,
}) {
return
Expand Down

0 comments on commit b9ac9d9

Please sign in to comment.