diff --git a/target_snowflake/db_sync.py b/target_snowflake/db_sync.py
index ffac46c5..aa542137 100644
--- a/target_snowflake/db_sync.py
+++ b/target_snowflake/db_sync.py
@@ -854,10 +854,6 @@ def _refresh_table_pks(self):
 
             queries.append(f'alter table {table_name} add primary key({pk_list});')
 
-        # For now, we don't wish to enforce non-nullability on the pk columns
-        for pk in current_pks.union(new_pks):
-            queries.append(f'alter table {table_name} alter column {safe_column_name(pk)} drop not null;')
-
         self.query(queries)
 
     def _get_current_pks(self) -> Set[str]: