Log the incremental value used

PostHog · Dec 19, 2024 · d3bfcba · d3bfcba
1 parent 82c7b02
commit d3bfcba
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/posthog/temporal/data_imports/workflow_activities/import_data_sync.py b/posthog/temporal/data_imports/workflow_activities/import_data_sync.py
@@ -101,6 +101,9 @@ def import_data_activity_sync(inputs: ImportDataActivityInputs):
                 schema.sync_type_config.get("incremental_field_type"),
             )
 
+        if schema.is_incremental:
+            logger.debug(f"Incremental last value being used is: {processed_incremental_last_value}")
+
         source = None
         if model.pipeline.source_type == ExternalDataSource.Type.STRIPE:
             from posthog.temporal.data_imports.pipelines.stripe import stripe_source