Skip to content

Commit 8f9f210

Browse files
author
fn500i
committed
more clean-up
Signed-off-by: fn500i <[email protected]>
1 parent b999ccd commit 8f9f210

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

src/connectors/impls/psql_repl/postgres_replication.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -287,8 +287,6 @@ pub(crate) async fn replication(connection_config:MzConfig, publication : &str,
287287
mz_postgres_util::publication_info(&connection_config, publication, None).await?;
288288
let source_id = "source_id";
289289
let mut _replication_lsn = PgLsn::from(0);
290-
// let mut postgres_tables = Vec::new();
291-
// let publication_tables = mz_postgres_util::publication_info(&connection_config, publication, None).await?;
292290
let publication_tables_json = serde_json::to_string(&PublicationTables{publication_tables: publication_tables.clone()})?;
293291
let json_obj = serde_json::from_str::<tremor_value::Value>(&publication_tables_json)?;
294292
dbg!(&publication_tables_json);

0 commit comments

Comments
 (0)