Skip to content

Commit 702f74a

Browse files
committed
cleanup
1 parent 93b6c92 commit 702f74a

2 files changed

Lines changed: 6 additions & 6 deletions

File tree

integration/copy_data/pgdog.toml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,3 @@ data_type = "bigint"
5656

5757
[admin]
5858
password = "pgdog"
59-
60-
[rewrite]
61-
primary_key = "rewrite_omni"

pgdog/src/backend/replication/logical/orchestrator.rs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ use crate::{
77
},
88
util::{format_bytes, human_duration, random_string},
99
};
10-
use pgdog_config::{ConfigAndUsers, CutoverTimeoutAction};
10+
use pgdog_config::{ConfigAndUsers, CutoverTimeoutAction, RewriteMode};
1111
use std::{fmt::Display, sync::Arc, time::Duration};
1212
use tokio::{
1313
select,
@@ -109,8 +109,11 @@ impl Orchestrator {
109109

110110
self.refresh_publisher();
111111

112-
// Install our stuff.
113-
Schema::install(&self.destination).await?;
112+
if self.destination.rewrite().primary_key == RewriteMode::RewriteOmni {
113+
// Install the sharded sequence and supporting schema
114+
// and functions.
115+
Schema::install(&self.destination).await?;
116+
}
114117

115118
Ok(())
116119
}

0 commit comments

Comments
 (0)