fix pks

jlloyd-widen · Mar 8, 2024 · 4d3e1eb · 4d3e1eb
1 parent ae1b210
commit 4d3e1eb
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/tap_clari/streams.py b/tap_clari/streams.py
@@ -20,7 +20,12 @@ def __init__(self, tap, forecast_id: str):
         )
         self.forecast_id = forecast_id
 
-    primary_keys: t.ClassVar[list[str]] = ["entries"]
+    primary_keys: t.ClassVar[list[str]] = [
+        "fieldId",
+        "timeFrameId",
+        "timePeriodId",
+        "userId"
+    ]
     replication_key = None
     schema = th.PropertiesList(
         th.Property("adjustmentValue", th.NumberType),