From 641a9c9e1a6bde943d77c94a3a6ff5cfe1ca1d37 Mon Sep 17 00:00:00 2001 From: Neeraj Gupta <254676+ua741@users.noreply.github.com> Date: Mon, 12 Aug 2024 16:39:36 +0530 Subject: [PATCH] [server] Minor fixes --- server/pkg/controller/filedata/replicate.go | 2 +- server/pkg/repo/filedata/repository.go | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) 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`