Merge 6205174 into 42fcca9

getdozer · Feb 6, 2023 · 2a9285c · 2a9285c
2 parents 42fcca9 + 6205174
commit 2a9285c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/dozer-ingestion/src/connectors/postgres/schema_helper.rs b/dozer-ingestion/src/connectors/postgres/schema_helper.rs
@@ -11,7 +11,7 @@ use crate::connectors::{TableInfo, ValidationResults};
 use crate::connectors::postgres::connection::helper;
 use crate::connectors::postgres::helper::postgres_type_to_dozer_type;
 use crate::errors::PostgresSchemaError::{
-    InvalidColumnType, SchemaReplicationIdentityError, ValueConversionError,
+    InvalidColumnType, PrimaryKeyIsMissingInSchema, ValueConversionError,
 };
 
 use postgres_types::Type;
@@ -173,7 +173,7 @@ impl SchemaHelper {
             .find(|(_table_name, schema, _)| schema.primary_index.is_empty());
 
         match table_without_primary_index {
-            Some((table_name, _, _)) => Err(SchemaReplicationIdentityError(table_name.clone())),
+            Some((table_name, _, _)) => Err(PrimaryKeyIsMissingInSchema(table_name.clone())),
             None => Ok(()),
         }
     }

diff --git a/dozer-ingestion/src/errors.rs b/dozer-ingestion/src/errors.rs
@@ -165,8 +165,8 @@ pub enum PostgresConnectorError {
 
 #[derive(Error, Debug, Eq, PartialEq)]
 pub enum PostgresSchemaError {
-    #[error("Schema's '{0}' replication identity settings is not correct. It is either not set or NOTHING")]
-    SchemaReplicationIdentityError(String),
+    #[error("Schema's '{0}' doesnt have primary key")]
+    PrimaryKeyIsMissingInSchema(String),
 
     #[error("Column type {0} not supported")]
     ColumnTypeNotSupported(String),