diff --git a/tap_salesforce/__init__.py b/tap_salesforce/__init__.py index 13199d0..0eb9c75 100644 --- a/tap_salesforce/__init__.py +++ b/tap_salesforce/__init__.py @@ -227,7 +227,7 @@ def do_discover(sf): if replication_key: mdata = metadata.write( - mdata, (), 'valid-replication-keys', [replication_key]) + mdata, (), 'replication-key', replication_key) else: mdata = metadata.write( mdata,