diff --git a/server/pkg/controller/filedata/replicate.go b/server/pkg/controller/filedata/replicate.go index 1cf4488d70..90afa6169e 100644 --- a/server/pkg/controller/filedata/replicate.go +++ b/server/pkg/controller/filedata/replicate.go @@ -21,7 +21,7 @@ func (c *Controller) StartReplication() error { if workerURL == "" { log.Infof("replication.worker-url was not defined, file data will downloaded directly during replication") } else { - log.Infof("Worker URL to download objects for replication v3 is: %s", workerURL) + log.Infof("Worker URL to download objects for file-data replication is: %s", workerURL) } c.workerURL = workerURL diff --git a/server/pkg/repo/filedata/repository.go b/server/pkg/repo/filedata/repository.go index 9f5dc5cf3f..78dad2aebf 100644 --- a/server/pkg/repo/filedata/repository.go +++ b/server/pkg/repo/filedata/repository.go @@ -42,6 +42,7 @@ func (r *Repository) InsertOrUpdate(ctx context.Context, data filedata.Row) erro WHERE elem IS NOT NULL AND elem != EXCLUDED.latest_bucket ), replicated_buckets = ARRAY[]::s3region[], + pending_sync = true, latest_bucket = EXCLUDED.latest_bucket, updated_at = now_utc_micro_seconds() WHERE file_data.is_deleted = false`