Merge pull request #81 from openedx/bmtcril/ralph_4

refactor!: Update expected CH schema to match Ralph 4.0

Author: bmtcril

xapi_db_load/__init__.py

@@ -2,4 +2,4 @@
 Scripts to generate fake xAPI data against various backends.
 """
 
-__version__ = "1.0"
+__version__ = "1.1"

xapi_db_load/backends/clickhouse_lake.py

@@ -76,7 +76,7 @@ def batch_insert(self, events):
         out_data = []
         for v in events:
             try:
-                out = f"('{v['event_id']}', '{v['emission_time']}', '{v['event']}', '{v['event']}')"
+                out = f"('{v['event_id']}', '{v['emission_time']}', '{v['event']}')"
                 out_data.append(out)
             except Exception:
                 print(v)
@@ -86,8 +86,7 @@ def batch_insert(self, events):
                 INSERT INTO {self.event_raw_table_name} (
                     event_id,
                     emission_time,
-                    event,
-                    event_str
+                    event
                 )
                 VALUES {vals}
             """