[server] Minor fixes

ente-io · Aug 12, 2024 · 641a9c9 · 641a9c9
1 parent 6259a97
commit 641a9c9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -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`