Merge pull request #1948 from estuary/luis/source-impact-native

source-impact-native: removing logcursor check for Actions streams
estuary · Sep 23, 2024 · 2bd343d · 2bd343d
2 parents 9413f24 + 9d75621
commit 2bd343d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/source-impact-native/source_impact_native/api.py b/source-impact-native/source_impact_native/api.py
@@ -143,10 +143,7 @@ async def fetch_incremental_actions(
                     max_ts = _s_to_dt(results[f"CreationDate"])
                     doc = _cls.model_validate_json(json.dumps(results))
                     yield doc
-
-                elif _s_to_dt(results[f"CreationDate"]) < log_cursor:
-                    iterating = False
-                    break
+
             if result.get("@nextpageuri"):
                 url = API + result["@nextpageuri"]
             else:

diff --git a/source-impact-native/source_impact_native/resources.py b/source-impact-native/source_impact_native/resources.py
@@ -178,7 +178,7 @@ def open(
             state,
             task,
             fetch_snapshot=functools.partial(fetch_snapshot, cls, account_sid, http),
-            tombstone=cls.PRIMARY_KEY,
+            tombstone=cls(_meta=cls.Meta(op="d")),
         )
 
     return Resource(
@@ -250,7 +250,7 @@ def open(
             state,
             task,
             fetch_snapshot=functools.partial(fetch_snapshot_child, cls_parent, cls, account_sid, http),
-            tombstone=cls.PRIMARY_KEY,
+            tombstone=cls(_meta=cls.Meta(op="d")),
         )
 
     return Resource(