fix primary key

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