Merge pull request #20 from MeltanoLabs/bugfix-pks-not-populating

fix: PKs not populating
MeltanoLabs · Apr 18, 2023 · be786d3 · be786d3
2 parents 442a431 + 4cd2a55
commit be786d3
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/tap_dynamodb/streams.py b/tap_dynamodb/streams.py
@@ -34,11 +34,7 @@ def __init__(
         self._table_name: str = name
         self._schema: dict = {}
         self._infer_schema_sample_size = infer_schema_sample_size
-        super().__init__(
-            tap=tap,
-            schema=self.schema,
-            name=name,
-        )
+        super().__init__(name=name, tap=tap)
 
     def get_records(self, context: dict | None) -> Iterable[dict]:
         for batch in self._dynamodb_conn.get_items_iter(self._table_name):
@@ -59,7 +55,7 @@ def schema(self) -> dict:
                 self._table_name,
                 self._infer_schema_sample_size,
             )
-            self.primary_keys = self._dynamodb_conn.get_table_key_properties(
+            self._primary_keys = self._dynamodb_conn.get_table_key_properties(
                 self._table_name
             )
         return self._schema