From 4d3e1ebb23df641e13fe4f95a8facebcb95a088c Mon Sep 17 00:00:00 2001 From: Josh lloyd Date: Fri, 8 Mar 2024 13:03:38 -0700 Subject: [PATCH] fix pks --- tap_clari/streams.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/tap_clari/streams.py b/tap_clari/streams.py index 9f6155c..e8f5ba9 100644 --- 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),