Merge pull request #350 from tinybirdco/fix/recover_from_quarantine

update recover from quarantine not having quotes

Author: jlmadurga

change_column_type_landing_and_recover_quarantine_data/README.md

@@ -26,7 +26,7 @@ NODE materialized
 
 SQL >
     SELECT 
-        assumeNotNull(parseDateTimeBestEffort(replaceAll(timestamp, '"', ''))) as timestamp,
+        assumeNotNull(parseDateTimeBestEffort(timestamp)) as timestamp,
         assumeNotNull(session_id) as session_id,
         toLowCardinality(assumeNotNull(action)) as action,
         toUInt32(assumeNotNull(version)) as version,

recover_data_from_quarantine/README.md

@@ -8,12 +8,12 @@ When data ends up in quarantine, it is possible to re-ingest it using a Copy Pip
   SQL >
       SELECT
           toDateTime(
-              fromUnixTimestamp64Milli(toUInt64(replaceAll(assumeNotNull(timestamp), '"', '')) * 1000)
+              fromUnixTimestamp64Milli(toUInt64(assumeNotNull(timestamp)) * 1000)
           ) timestamp,
-          replaceAll(assumeNotNull(session_id), '"', '') session_id,
-          replaceAll(assumeNotNull(action), '"', '') action,
-          replaceAll(assumeNotNull(version), '"', '') version,
-          replaceAll(assumeNotNull(payload), '"', '') payload
+          assumeNotNull(session_id) session_id,
+          assumeNotNull(action) action,
+          assumeNotNull(version) version,
+          assumeNotNull(payload) payload
       FROM analytics_events_quarantine
 
   TYPE COPY

recover_data_from_quarantine/pipes/analytics_events_quarantine_to_final.pipe

@@ -2,12 +2,12 @@ NODE copy_quarantine
 SQL >
     SELECT
         toDateTime(
-            fromUnixTimestamp64Milli(toUInt64(replaceAll(assumeNotNull(timestamp), '"', '')) * 1000)
+            fromUnixTimestamp64Milli(toUInt64(assumeNotNull(timestamp)) * 1000)
         ) timestamp,
-        replaceAll(assumeNotNull(session_id), '"', '') session_id,
-        replaceAll(assumeNotNull(action), '"', '') action,
-        replaceAll(assumeNotNull(version), '"', '') version,
-        replaceAll(assumeNotNull(payload), '"', '') payload
+        assumeNotNull(session_id) session_id,
+        assumeNotNull(action) action,
+        assumeNotNull(version) version,
+        assumeNotNull(payload) payload
     FROM analytics_events_quarantine
 
 TYPE COPY