diff --git a/tap_clari/streams.py b/tap_clari/streams.py index 5cb9dfd..a1acff9 100644 --- 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(