diff --git a/elx/catalog.py b/elx/catalog.py index b1be63b..44b488c 100644 --- a/elx/catalog.py +++ b/elx/catalog.py @@ -186,12 +186,6 @@ def set_replication_keys(self, replication_keys: Optional[dict]) -> "Catalog": # Update the replication key value stream.replication_key = replication_key - # Add the replication key to stream metadata - stream.upsert_metadata( - breadcrumb=[], - metadata={"valid-replication-keys": [replication_key]}, - ) - # Set inclusion of replication property metadata to `automatic` stream.upsert_metadata( breadcrumb=["properties", replication_key],