sources and add events

models/bronze/bronze__add_events.sql

@@ -14,6 +14,7 @@ SELECT
   pool,
   event_id,
   block_timestamp,
+  _TX_TYPE,
   __HEVO__DATABASE_NAME,
   __HEVO__SCHEMA_NAME,
   __HEVO__INGESTED_AT,

models/gold/defi/defi__fact_add_events.sql

@@ -20,6 +20,7 @@ WITH base AS (
     e.from_address,
     e.asset,
     e.event_id,
+    e._TX_TYPE,
     _inserted_timestamp
   FROM
     {{ ref('silver__add_events') }}
@@ -63,6 +64,7 @@ SELECT
   A.to_address,
   A.from_address,
   A.asset,
+  A._TX_TYPE,
   A._inserted_timestamp,
   '{{ invocation_id }}' AS _audit_run_id,
   SYSDATE() AS inserted_timestamp,

models/silver/silver__add_events.sql

@@ -14,6 +14,7 @@ SELECT
   pool AS pool_name,
   event_id,
   block_timestamp,
+  _TX_TYPE,
   DATEADD(
     ms,
     __HEVO__LOADED_AT,

models/sources.yml

@@ -8,7 +8,7 @@ sources:
       - name: prices_v2
   - name: thorchain_midgard
     database: HEVO
-    schema: THORCHAIN_MIDGARD_2_17
+    schema: THORCHAIN_MIDGARD_2_22_3
     tables:
       - name: midgard_active_vault_events
       - name: midgard_add_events