fix log sync ref and log projection test name

singer-io · Feb 1, 2022 · a0e8cf7 · a0e8cf7
1 parent ca53828
commit a0e8cf7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/tap_dynamodb/sync_strategies/log_based.py b/tap_dynamodb/sync_strategies/log_based.py
@@ -145,7 +145,7 @@ def sync(config, state, stream):
 
     md_map = metadata.to_map(stream['metadata'])
     projection = metadata.get(md_map, (), 'tap-mongodb.projection')
-    expression = metadata.get(md_map, (), 'tap-dynamodb.expression-attribute')
+    expression = metadata.get(md_map, (), 'tap-dynamodb.expression-attributes')
     if projection is not None:
         projection = [x.strip().split('.') for x in projection.split(',')]
         if expression:

diff --git a/tests/test_dynamodb_log_based_projections.py b/tests/test_dynamodb_log_based_projections.py
@@ -65,7 +65,7 @@ def generate_items(self, num_items, start_key=0):
 
     @staticmethod
     def name():
-        return "tap_tester_dynamodb_log_based_projections"
+        return "tt_dynamodb_log_projections"
 
     def test_run(self):
         (table_configs, conn_id, expected_streams) = self.pre_sync_test()