@@ -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
|
||||
|
||||
|
||||
@@ -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`
|
||||
|
||||
Reference in New Issue
Block a user