feat: _sdc_timestamp (#5)

* _sdc_timestamp

* unix_time as replication key

* remove testing snippet

meltano.yml

@@ -20,7 +20,7 @@ plugins:
     - name: secret_key
       sensitive: true
     - name: start_date
-      kind: integer
+      kind: date_iso8601
   loaders:
   - name: target-jsonl
     variant: andyh1203

tap_calltrackingmetrics/streams.py

@@ -64,13 +64,18 @@ def get_url_params(
         next_page_token: t.Any | None,
     ) -> dict[str, t.Any]:
         params = super().get_url_params(context, next_page_token)
-        starting_replication_key_value = self.get_starting_replication_key_value(
-            context
-        ) or self.config.get("start_date")
-        if "start_date" not in params and starting_replication_key_value is not None:
+        starting_replication_key_value = self.get_starting_replication_key_value(context)  # noqa: E501
+        start_date = None
+        if isinstance(starting_replication_key_value, str):
+            start_date = datetime.datetime.fromisoformat(
+                starting_replication_key_value
+            ).strftime("%Y-%m-%d")
+        elif isinstance(starting_replication_key_value, int):
             start_date = datetime.datetime.fromtimestamp(
-                starting_replication_key_value, tz=datetime.timezone.utc
+                starting_replication_key_value,
+                tz=datetime.timezone.utc,
             ).strftime("%Y-%m-%d")
+        if start_date is not None:
             params["start_date"] = start_date
         return params
 

tap_calltrackingmetrics/tap.py

@@ -31,10 +31,10 @@ class TapCallTrackingMetrics(Tap):
         ),
         th.Property(
             "start_date",
-            th.IntegerType,
+            th.DateTimeType,
             required=False,
             title="Start Date",
-            description="Formatted as a Unix timestamp.",
+            description="The earliest record to sync.",
         ),
     ).to_dict()