An 2482/succeeded (#83)

* merge main & add in tx_succeeded column

* ready for primetime

* fix more merge conflicts

* locked liquidity actiions bug

* transfer update

* locked liquidity balances and

* update seed file for tests

* merge in remote branch

Co-authored-by: Eric Laurello <eric.laurello@flipsidecrypto.com>

data/testing__daily_balances.csv

@@ -1,96 +1,98 @@
 date,balance_type,address,currency,balance
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/5,156901013595522054654364
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/637,0
 2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/B3FB7128CE957DE1ADB687A919AA0786C77C62FB1280C07CDD78AEA032D56853,0
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/497,0
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/600,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/9712DBB13B9631EDFA9BF61B55F1B2D290B2ADB67E3A4EB3A875F3B6081B3B84,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/771,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/613,0
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/00B6E60AD3D65CBEF5579AC8AF609527C0B57535B6E32D96C80A735344FD9DCC,3911192009
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/498,0
-2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/605,0
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858,500008565
-2022-07-17,liquid,osmo1ka4zctlzr2uee5s29y9qn2rcer3hcaunxvcptc,ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858,0
-2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/606,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/5,0
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/BE1BB42D4BE3C30D50B68D7C41DB4DFCE9678E8EF8C539F6E6A9345048894FCC,209050
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/765,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/767,0
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/584,5211764319661687113
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/766,0
-2022-07-17,staked,osmo1ka4zctlzr2uee5s29y9qn2rcer3hcaunxvcptc,uosmo,14885383
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/27394FB092D2ECCD56123C74F36E4C1F926001CEADA9CA97EA622B25F41E5EB2,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/756,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/4E5444C35610CC76FC94E7F7886B93121175C28262DDFDDE6F84E82BF2425452,0
-2022-07-17,staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,uosmo,102334774
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/601,5543512741386206132
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/EA3E1640F9B1532AB129A571203A0B9F789A7F14BB66E350DCBFA18E1A1931F0,967659
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/CBA34207E969623D95D057D9B11B0C8B32B89A71F170577D982FDDE623813FFC,1149014
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/690,56084938505868894999
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/6AE98883D4D5D5FF9E50D7130F1305DA2FFA0C652D1DD9C123657C6B4EB2DF8A,125010149067303700000
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/BE1BB42D4BE3C30D50B68D7C41DB4DFCE9678E8EF8C539F6E6A9345048894FCC,0
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/498,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/751,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/690,47627625428299477685
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/52B1AA623B34EB78FD767CEA69E8D7FA6C9CFE1FBF49C5406268FD325E2CC2AC,4977123627
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/560,-722862402734530320250
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/7F1A862E98185A286F011DD093D8BD2FA1B7CD1A723EC5E6C59F76692F1728F7,371983
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/498,12939530377800458661
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/600,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/56C276FC136E239449DCE664292DBEEF5795C4EF4B5B35DB98BD1C0948274867,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/239A507997222805E441956EBE8087D7E2D05D6535C6D4C75EF8DCF83B3DE1A1,0
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/611,14262075310226757145
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/604,12258739039587559
-2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/604,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/608,0
-2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/1,101398840842185453211
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/46B44899322F3CD854D2D46DEEF881958467CDD4B3B10086DA49296BBED94BED,10278225
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/604,0
-2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/9,127540954286104745272018
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/0EF15DF2F02480ADE0BB6E85D9EBB5DAEA2836D3860E9F97F9AADE4F57A31AA0,825640692
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/0954E1C28EB7AF5B72D24F3BC2B47BBB2FDF91BDDFD57B74B99E133AED40972A,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/497,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858,133770065
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/8061A06D3BD4D52C4A28FFECF7150D370393AF0BA661C3776C54FF32836C3961,0
 2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/1DE9A32D603EE05E9B8619DF24D90FD518C932AE0B5B3209A986B7262DBADE2A,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/E6931F78057F7CC5DA0FD6CEF82FF39373A6E0452BF1FD76910B93292CF356C1,0
+2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/606,4686338563878355485050
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/6AE98883D4D5D5FF9E50D7130F1305DA2FFA0C652D1DD9C123657C6B4EB2DF8A,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/690,47627625428299477685
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/497,34442316185562221868
+2022-07-17,liquid,osmo1ka4zctlzr2uee5s29y9qn2rcer3hcaunxvcptc,uosmo,20304
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/498,12939530377800458661
 2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/1,570089175584047961768
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/7ABF696369EFB3387DF22B6A24204459FE5EFD010220E8E5618DC49DB877047B,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/7F1A862E98185A286F011DD093D8BD2FA1B7CD1A723EC5E6C59F76692F1728F7,371983
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/00B6E60AD3D65CBEF5579AC8AF609527C0B57535B6E32D96C80A735344FD9DCC,3911192009
+2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/605,5039040092969689838656
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/BE1BB42D4BE3C30D50B68D7C41DB4DFCE9678E8EF8C539F6E6A9345048894FCC,209050
+2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/498,12939530377800458661
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/601,5543512741386206132
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/AA1C80225BCA7B32ED1FC6ABF8B8E899BEB48ECDB4B417FD69873C6D715F97E7,6216
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/EA3E1640F9B1532AB129A571203A0B9F789A7F14BB66E350DCBFA18E1A1931F0,967659
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/9BBA9A1C257E971E38C1422780CE6F0B0686F0A3085E2D61118D904BFE0F5F5E,68884880
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/0954E1C28EB7AF5B72D24F3BC2B47BBB2FDF91BDDFD57B74B99E133AED40972A,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/560,18665319896957969882
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/4E5444C35610CC76FC94E7F7886B93121175C28262DDFDDE6F84E82BF2425452,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/5,156901013595522054654364
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/FE2CD1E6828EC0FAB8AF39BAC45BC25B965BA67CCBC50C13A14BD610B0D1E2C4,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/9BBC8BD41DC282F0DF4709ED7562F5B12F161D8DD391386B79EF179AA50621C3,0
+2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/1,101398840842185453211
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/EB7FB9C8B425F289B63703413327C2051030E848CE4EAAEA2E51199D6D39D3EC,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/8A34AF0C1943FD0DFCDE9ADBF0B2C9959C45E87E6088EA2FC6ADACD59261B8A2,0
+2022-07-17,staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,uosmo,102334774
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/768,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/771,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/600,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/49C2B2C444B7C5F0066657A4DBF19D676E0D185FF721CFD3E14FA253BCB9BC04,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/1,511070108766580702658
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/611,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/BE1BB42D4BE3C30D50B68D7C41DB4DFCE9678E8EF8C539F6E6A9345048894FCC,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/27394FB092D2ECCD56123C74F36E4C1F926001CEADA9CA97EA622B25F41E5EB2,0
+2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/560,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/816,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/717,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/239A507997222805E441956EBE8087D7E2D05D6535C6D4C75EF8DCF83B3DE1A1,0
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/6AE98883D4D5D5FF9E50D7130F1305DA2FFA0C652D1DD9C123657C6B4EB2DF8A,125010149067303700000
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/0EF15DF2F02480ADE0BB6E85D9EBB5DAEA2836D3860E9F97F9AADE4F57A31AA0,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/41999DF04D9441DAC0DF5D8291DF4333FBCBA810FFD63FDCE34FDF41EF37B6F7,0
+2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/604,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/765,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/9712DBB13B9631EDFA9BF61B55F1B2D290B2ADB67E3A4EB3A875F3B6081B3B84,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/9989AD6CCA39D1131523DB0617B50F6442081162294B4795E26746292467B525,860527644
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/637,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/498,109158534505780395464
 2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/678,275748711600873358
 2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/987C17B11ABC2B20019178ACE62929FE9840202CE79498E29FE8E5CB02B7C0A4,864436739
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/621,0
-2022-07-17,superfluid staked,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/1,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858,133770065
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/9,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/49C2B2C444B7C5F0066657A4DBF19D676E0D185FF721CFD3E14FA253BCB9BC04,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/584,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/9BBC8BD41DC282F0DF4709ED7562F5B12F161D8DD391386B79EF179AA50621C3,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/987C17B11ABC2B20019178ACE62929FE9840202CE79498E29FE8E5CB02B7C0A4,9447867
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/9,0
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/B9E0A1A524E98BB407D3CED8720EFEFD186002F90C1B1B7964811DD0CCC12228,218286123
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/768,0
-2022-07-17,liquid,osmo1ka4zctlzr2uee5s29y9qn2rcer3hcaunxvcptc,uosmo,20304
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/6AE98883D4D5D5FF9E50D7130F1305DA2FFA0C652D1DD9C123657C6B4EB2DF8A,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/46B44899322F3CD854D2D46DEEF881958467CDD4B3B10086DA49296BBED94BED,0
-2022-07-17,locked liquidity,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/498,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/0EF15DF2F02480ADE0BB6E85D9EBB5DAEA2836D3860E9F97F9AADE4F57A31AA0,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/577,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/8061A06D3BD4D52C4A28FFECF7150D370393AF0BA661C3776C54FF32836C3961,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/816,0
-2022-07-17,staked,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,uosmo,100298879
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/553,2988730689240198679174476547
-2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/1,511070108766580702658
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,uosmo,15452376
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,uosmo,2275039
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/27394FB092D2ECCD56123C74F36E4C1F926001CEADA9CA97EA622B25F41E5EB2,8365193
-2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/9BBA9A1C257E971E38C1422780CE6F0B0686F0A3085E2D61118D904BFE0F5F5E,68884880
-2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/560,-298645118351327518112
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/FE2CD1E6828EC0FAB8AF39BAC45BC25B965BA67CCBC50C13A14BD610B0D1E2C4,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/717,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/611,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/8A34AF0C1943FD0DFCDE9ADBF0B2C9959C45E87E6088EA2FC6ADACD59261B8A2,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/497,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/41999DF04D9441DAC0DF5D8291DF4333FBCBA810FFD63FDCE34FDF41EF37B6F7,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/AA1C80225BCA7B32ED1FC6ABF8B8E899BEB48ECDB4B417FD69873C6D715F97E7,6216
 2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/423967B46B1A51D78619085105B04FCFA14F7CBC0BE7539A316B2DCDFC7D8C07,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/9989AD6CCA39D1131523DB0617B50F6442081162294B4795E26746292467B525,860527644
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/EB7FB9C8B425F289B63703413327C2051030E848CE4EAAEA2E51199D6D39D3EC,0
-2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/8E697BDABE97ACE8773C6DF7402B2D1D5104DD1EEABE12608E3469B7F64C15BA,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/987C17B11ABC2B20019178ACE62929FE9840202CE79498E29FE8E5CB02B7C0A4,9447867
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858,500008565
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/27394FB092D2ECCD56123C74F36E4C1F926001CEADA9CA97EA622B25F41E5EB2,8365193
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/498,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/56C276FC136E239449DCE664292DBEEF5795C4EF4B5B35DB98BD1C0948274867,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/8E697BDABE97ACE8773C6DF7402B2D1D5104DD1EEABE12608E3469B7F64C15BA,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/766,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/690,56084938505868894999
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,uosmo,15452376
+2022-07-17,superfluid staked,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/9,127540954286104745272018
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/577,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/9,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/767,0
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/0EF15DF2F02480ADE0BB6E85D9EBB5DAEA2836D3860E9F97F9AADE4F57A31AA0,825640692
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/A8CA5EE328FA10C9519DF6057DA1F69682D28F7D0F5CCC7ECB72E3DCA2D157A4,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/621,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/584,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/71055835C7639739EAE03AACD1324FE162DBA41D09F197CB72D966D014225B1C,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/CBA34207E969623D95D057D9B11B0C8B32B89A71F170577D982FDDE623813FFC,1149014
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/9,1277058429129285545890
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/751,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/604,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/756,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/E6931F78057F7CC5DA0FD6CEF82FF39373A6E0452BF1FD76910B93292CF356C1,0
+2022-07-17,liquid,osmo1ka4zctlzr2uee5s29y9qn2rcer3hcaunxvcptc,ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/600,68619721244831
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/553,2988730689240198679174476547
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,uosmo,2275039
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/611,14262075310226757145
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/608,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/5,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/7ABF696369EFB3387DF22B6A24204459FE5EFD010220E8E5618DC49DB877047B,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/613,0
+2022-07-17,liquid,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,ibc/46B44899322F3CD854D2D46DEEF881958467CDD4B3B10086DA49296BBED94BED,0
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/584,5211764319661687113
+2022-07-17,locked liquidity,osmo195khh6nr3zsvaxkm53wavkxv46uucdlatdux5m,gamm/pool/604,12258739039587559
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/46B44899322F3CD854D2D46DEEF881958467CDD4B3B10086DA49296BBED94BED,10278225
+2022-07-17,superfluid staked,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,gamm/pool/1,0
+2022-07-17,staked,osmo1ka4zctlzr2uee5s29y9qn2rcer3hcaunxvcptc,uosmo,14885383
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/B9E0A1A524E98BB407D3CED8720EFEFD186002F90C1B1B7964811DD0CCC12228,218286123
+2022-07-17,staked,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,uosmo,100298879
+2022-07-17,liquid,osmo1fjh798fyn9vqldc8ru09c99r89v5mt3czu4jfp,ibc/52B1AA623B34EB78FD767CEA69E8D7FA6C9CFE1FBF49C5406268FD325E2CC2AC,4977123627

models/core/core__fact_airdrop.sql

@@ -9,6 +9,7 @@ SELECT
     chain_id, 
     tx_id, 
     tx_status, 
+    tx_succeeded,
     transfer_type, 
     sender, 
     amount, 

models/core/core__fact_airdrop.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_airdrop
-    description: Record of the OSMO airdrop to ATOM stakers. 
+    description: Record of the OSMO airdrop to ATOM stakers. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: TRANSFER_TYPE
         description: "{{ doc('transfer_type') }}"
         tests: 

models/core/core__fact_governance_proposal_deposits.sql

@@ -9,6 +9,7 @@ SELECT
     chain_id, 
     tx_id, 
     tx_status, 
+    tx_succeeded,
     depositor, 
     proposal_id, 
     amount, 

models/core/core__fact_governance_proposal_deposits.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_governance_proposal_deposits
-    description: Records of all proposal deposits that have occurred on Osmosis, dating back to the genesis block. At least 500 OSMO must be deposited for a proposal to be voted on.
+    description: Records of all proposal deposits that have occurred on Osmosis, dating back to the genesis block. At least 500 OSMO must be deposited for a proposal to be voted on. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: DEPOSITOR 
         description: "{{ doc('depositor') }}"
         tests: 

models/core/core__fact_governance_submit_proposal.sql

@@ -9,6 +9,7 @@ SELECT
     chain_id, 
     tx_id, 
     tx_status, 
+    tx_succeeded,
     proposer, 
     proposal_id, 
     proposal_type

models/core/core__fact_governance_submit_proposal.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_governance_submit_proposal
-    description: Records of all proposal submissions on Osmosis, dating back to the Genesis block. 
+    description: Records of all proposal submissions on Osmosis, dating back to the Genesis block. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: PROPOSER
         description: "{{ doc('proposer') }}"
         tests: 

models/core/core__fact_governance_votes.sql

@@ -8,7 +8,8 @@ SELECT
     blockchain, 
     chain_id, 
     tx_id, 
-    tx_status, 
+    tx_status,
+    tx_succeeded, 
     voter, 
     proposal_id, 
     vote_option, 

models/core/core__fact_governance_votes.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_governance_votes
-    description: Records of all votes on proposals. 
+    description: Records of all votes on proposals. The columns blockchain, chain_id, and tx_status will be deprecating soon. 
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: VOTER
         description: "{{ doc('voter') }}"
         tests: 

models/core/core__fact_liquidity_provider_actions.sql

@@ -9,6 +9,7 @@ SELECT
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     liquidity_provider_address,
     action,
     pool_id :: ARRAY as pool_id,
@@ -25,6 +26,7 @@ SELECT
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     liquidity_provider_address,
     action,
     pool_id,

models/core/core__fact_liquidity_provider_actions.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_liquidity_provider_actions
-    description: Includes all actions entering and exiting liquidity pools  
+    description: Includes all actions entering and exiting liquidity pools. The columns blockchain, chain_id, and tx_status will be deprecating soon.  
     tests:
       - dbt_utils.unique_combination_of_columns:
           combination_of_columns:
@@ -32,6 +32,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: LIQUIDITY_PROVIDER_ADDRESS
         description: "{{ doc('liquidity_provider_address') }}"
         tests: 

models/core/core__fact_locked_liquidity_actions.sql

@@ -9,6 +9,7 @@ SELECT
     A.chain_id,
     A.tx_id,
     A.tx_status,
+    A.tx_succeeded,
     A.msg_group,
     A.msg_type,
     A.msg_action,

models/core/core__fact_locked_liquidity_actions.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_locked_liquidity_actions
-    description: Includes all actions related to locked LP tokens
+    description: Includes all actions related to locked LP tokens. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: MSG_GROUP
         description: "{{ doc('msg_group') }}"
         tests: 

models/core/core__fact_msg_attributes.sql

@@ -8,6 +8,7 @@ SELECT
     blockchain,
     chain_id,
     tx_id,
+    tx_succeeded,
     CONCAT(
         msg_group,
         ':',

models/core/core__fact_msg_attributes.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_msg_attributes
-    description: Records of all message attributes associated to messages that have occurred on Osmosis, dating back to the genesis block. 
+    description: Records of all message attributes associated to messages that have occurred on Osmosis, dating back to the genesis block. The columns blockchain and chain_id will be deprecating soon. 
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -23,6 +23,10 @@ models:
         description: "{{ doc('tx_id') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: MSG_GROUP
         description: "{{ doc('msg_group') }}"
         tests: 

models/core/core__fact_msgs.sql

@@ -9,6 +9,7 @@ SELECT
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     CONCAT(
         msg_group,
         ':',

models/core/core__fact_msgs.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_msgs
-    description: Records of all message attributes associated to messages that have occurred on Osmosis, dating back to the genesis block. 
+    description: Records of all message attributes associated to messages that have occurred on Osmosis, dating back to the genesis block. The columns blockchain, chain_id, and tx_status will be deprecating soon. 
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: MSG_GROUP
         description: "{{ doc('msg_group') }}"
         tests: 

models/core/core__fact_staking.sql

@@ -9,6 +9,7 @@ SELECT
     chain_id, 
     tx_id, 
     tx_status, 
+    tx_succeeded,
     tx_caller_address, 
     action, 
     delegator_address,

models/core/core__fact_staking.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_staking
-    description: Records of all staking related transactions that have occurred on Osmosis, dating back to the genesis block. These actions include delegate, undelegate, and redelegate.
+    description: Records of all staking related transactions that have occurred on Osmosis, dating back to the genesis block. These actions include delegate, undelegate, and redelegate. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: TX_CALLER_ADDRESS
         description: "{{ doc('tx_caller_address') }}"
         tests: 

models/core/core__fact_staking_rewards.sql

@@ -8,7 +8,8 @@ SELECT
     blockchain, 
     chain_id, 
     tx_id, 
-    tx_status, 
+    tx_status,
+    tx_succeeded, 
     tx_caller_address, 
     action, 
     delegator_address,

models/core/core__fact_staking_rewards.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_staking_rewards
-    description: Records of all claimed rewards earned from staking that have occurred on Osmosis, dating back to the genesis block. These actions include claim and withdrawal_rewards.
+    description: Records of all claimed rewards earned from staking that have occurred on Osmosis, dating back to the genesis block. These actions include claim and withdrawal_rewards. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: TX_CALLER_ADDRESS
         description: "{{ doc('tx_caller_address') }}"
         tests: 

models/core/core__fact_superfluid_staking.sql

@@ -9,7 +9,7 @@ SELECT
     chain_id,
     tx_id,
     tx_status,
-    {# tx_caller_address,  #}
+    tx_succeeded,
     action,
     delegator_address,
     amount,

models/core/core__fact_superfluid_staking.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_superfluid_staking
-    description: Records of all staking related transactions that have occurred on Osmosis, dating back to the genesis block. These actions include delegate, undelegate, and redelegate.
+    description: Records of all staking related transactions that have occurred on Osmosis, dating back to the genesis block. These actions include delegate, undelegate, and redelegate. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: ACTION
         description: "{{ doc('action') }}"
         tests: 

models/core/core__fact_swaps.sql

@@ -8,7 +8,8 @@ SELECT
     blockchain, 
     chain_id, 
     tx_id, 
-    tx_status, 
+    tx_status,
+    tx_succeeded, 
     trader, 
     from_amount, 
     from_currency, 

models/core/core__fact_swaps.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_swaps
-    description: Records of all transactions that have occurred on Osmosis, dating back to the genesis block. 
+    description: Records of all transactions that have occurred on Osmosis, dating back to the genesis block. The columns blockchain, chain_id, and tx_status will be deprecating soon. 
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: TRADER
         description: "{{ doc('trader') }}"
         tests: 

models/core/core__fact_transactions.sql

@@ -48,6 +48,7 @@ SELECT
     t.tx_id,
     s.tx_from,
     tx_status,
+    tx_succeeded,
     codespace,
     COALESCE(
         fee,

models/core/core__fact_transactions.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_transactions
-    description: Records of all transactions that have occurred on Osmosis, dating back to the genesis block. 
+    description: Records of all transactions that have occurred on Osmosis, dating back to the genesis block. The columns blockchain, chain_id, and tx_status will be deprecating soon. 
     tests:
       - dbt_utils.unique_combination_of_columns:
           combination_of_columns:
@@ -31,11 +31,15 @@ models:
         description: "{{ doc('tx_from') }}"
         tests: 
           - not_null: 
-              where: TX_STATUS = 'SUCCEEDED'
+              where: TX_SUCCEEDED = 'TRUE'
       - name: TX_STATUS
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: CODESPACE
         description: "{{ doc('codespace') }}"
         tests: 

models/core/core__fact_transfers.sql

@@ -8,7 +8,8 @@ SELECT
     blockchain, 
     chain_id, 
     tx_id, 
-    tx_status, 
+    tx_status,
+    tx_succeeded, 
     transfer_type, 
     sender, 
     amount, 

models/core/core__fact_transfers.yml

@@ -1,7 +1,7 @@
 version: 2
 models:
   - name: core__fact_transfers
-    description: Records of all transfers on Osmosis, including IBC transfers as on- and off-ramps to Osmosis and wallet to wallet transfers
+    description: Records of all transfers on Osmosis, including IBC transfers as on- and off-ramps to Osmosis and wallet to wallet transfers. The columns blockchain, chain_id, and tx_status will be deprecating soon.
     columns:
       - name: BLOCK_ID
         description: "{{ doc('block_id') }}"
@@ -27,6 +27,10 @@ models:
         description: "{{ doc('tx_status') }}"
         tests: 
           - dbt_expectations.expect_column_to_exist
+      - name: TX_SUCCEEDED
+        description: "{{ doc('tx_succeeded') }}"
+        tests: 
+          - dbt_expectations.expect_column_to_exist
       - name: TRANSFER_TYPE
         description: "{{ doc('transfer_type') }}"
         tests: 

models/descriptions/blockchain.md

@@ -1,5 +1,5 @@
 {% docs blockchain %}
 
-In this table, always Osmosis. Used to join to cross-chain tables. 
+In this table, always Osmosis. Used to join to cross-chain tables. This column will deprecate in all tables except core.fact_blocks soon. Please modify your queries to join to the blocks table to use this field. 
 
 {% enddocs %}

models/descriptions/chain_id.md

@@ -1,5 +1,5 @@
 {% docs chain_id %}
 
-The name and version of the blockchain. 
+The name and version of the blockchain. This column will deprecate in all tables except core.fact_blocks soon. Please modify your queries to join to the blocks table to use this field. 
 
 {% enddocs %}

models/descriptions/tx_status.md

@@ -1,5 +1,5 @@
 {% docs tx_status %}
 
-Transaction status is "SUCCEEDED" if the transaction went through, "FALSE" if the transaction failed. 
+Transaction status is "SUCCEEDED" if the transaction went through, "FALSE" if the transaction failed. This column is deprecating soon. Please switch over your queries to use the tx_succeeded column instead.
 
 {% enddocs %}

models/descriptions/tx_succeeded.md

@@ -0,0 +1,5 @@
+{% docs tx_succeeded %}
+
+Transaction status is "TRUE" if the transaction was successful, "FALSE" if the transaction failed. 
+
+{% enddocs %}

models/silver/silver__airdrops.sql

@@ -172,6 +172,7 @@ SELECT
     chain_id,
     r.tx_id,
     tx_status,
+    tx_succeeded,
     'AIRDROP' AS transfer_type,
     r.msg_index,
     sender,

models/silver/silver__airdrops.yml

@@ -55,7 +55,12 @@ models:
           - dbt_expectations.expect_column_values_to_be_in_type_list:
               column_type_list:
                 - STRING
-                - VARCHAR
+                - VARCHAR 
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: TRANSFER_TYPE
         description: "{{ doc('transfer_type') }}"
         tests: 

models/silver/silver__early_liquidity_provider_actions.sql

@@ -267,6 +267,7 @@ txn AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         _inserted_timestamp
     FROM
         {{ ref('silver__transactions') }}
@@ -290,6 +291,7 @@ SELECT
     tx.chain_id,
     tx.tx_id,
     tx.tx_status,
+    tx.tx_succeeded,
     d.msg_index,
     l.liquidity_provider_address,
     CASE

models/silver/silver__early_liquidity_provider_actions.yml

@@ -55,7 +55,12 @@ models:
           - dbt_expectations.expect_column_values_to_be_in_type_list:
               column_type_list:
                 - STRING
-                - VARCHAR
+                - VARCHAR 
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: LIQUIDITY_PROVIDER_ADDRESS
         description: "{{ doc('liquidity_provider_address') }}"
         tests: 

models/silver/silver__governance_proposal_deposits.sql

@@ -108,6 +108,7 @@ SELECT
     chain_id,
     p.tx_id,
     tx_status,
+    tx_succeeded,
     d.depositor,
     p.proposal_id :: NUMBER as proposal_id,
     v.amount,

models/silver/silver__governance_proposal_deposits.yml

@@ -54,6 +54,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: DEPOSITOR 
         description: "{{ doc('depositor') }}"
         tests: 

models/silver/silver__governance_submit_proposal.sql

@@ -92,6 +92,7 @@ SELECT
     chain_id,
     p.tx_id,
     tx_status,
+    tx_succeeded,
     proposer,
     p.proposal_id :: NUMBER AS proposal_id,
     y.proposal_type,

models/silver/silver__governance_submit_proposal.yml

@@ -54,6 +54,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: PROPOSER
         description: "{{ doc('proposer') }}"
         tests: 

models/silver/silver__governance_votes.sql

@@ -27,6 +27,7 @@ weighted_votes AS (
         chain_id, 
         tx_id, 
         tx_status, 
+        tx_succeeded,
         tx_body, 
         path :: STRING AS _path, 
         _inserted_timestamp
@@ -57,6 +58,7 @@ SELECT
     chain_id, 
     tx_id, 
     tx_status, 
+    tx_succeeded,
     path :: STRING AS _path, 
     this :proposal_id :: STRING AS proposal_id, 
     this :voter :: STRING AS voter, 
@@ -104,6 +106,7 @@ SELECT
     chain_id, 
     tx_id, 
     tx_status, 
+    tx_succeeded,
     _path, 
     b.value :proposal_id :: NUMBER AS proposal_id, 
     b.value :voter :: STRING AS voter, 

models/silver/silver__governance_votes.yml

@@ -58,6 +58,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: VOTER
         description: "{{ doc('voter') }}"
         tests: 

models/silver/silver__liquidity_provider_actions.sql

@@ -250,6 +250,7 @@ txn AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         _inserted_timestamp
     FROM
         {{ ref('silver__transactions') }}
@@ -275,6 +276,7 @@ SELECT
     tx.chain_id,
     d.tx_id,
     tx_status,
+    tx_succeeded,
     d.msg_index,
     l.liquidity_provider_address,
     CASE

models/silver/silver__liquidity_provider_actions.yml

@@ -56,6 +56,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: LIQUIDITY_PROVIDER_ADDRESS
         description: "{{ doc('liquidity_provider_address') }}"
         tests: 

models/silver/silver__locked_liquidity_actions.sql

@@ -27,6 +27,7 @@ base_msg_atts AS (
         A.chain_id,
         A.tx_id,
         'SUCCEEDED' AS tx_status,
+        'TRUE' AS tx_succeeded,
         A.msg_group,
         A.msg_type,
         A.attribute_key,
@@ -104,6 +105,7 @@ tx_msg_flat AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_group,
         _inserted_timestamp,
         LISTAGG(
@@ -129,6 +131,7 @@ tx_msg_flat AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_group,
         lock_id,
         _inserted_timestamp
@@ -141,6 +144,7 @@ msg_based AS (
         A.chain_id,
         A.tx_id,
         A.tx_status,
+        A.tx_succeeded,
         A.msg_group,
         A.msg_type,
         A.lock_id,
@@ -209,12 +213,13 @@ combo_with_super_undel AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_group,
         msg_type,
         lock_id,
         action,
         hybrid_action,
-        amount,
+        amount :: STRING AS amount,
         locker,
         DURATION,
         unlock_time,
@@ -230,12 +235,13 @@ combo_with_super_undel AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_group,
         msg_type,
         lock_id,
         action,
         hybrid_action,
-        amount,
+        amount :: STRING AS amount,
         locker,
         DURATION,
         unlock_time,
@@ -251,6 +257,7 @@ combo_with_super_undel AS (
         A.chain_id,
         A.tx_id,
         A.tx_status,
+        A.tx_succeeded,
         A.msg_group,
         A.msg_type,
         A.lock_id,
@@ -264,13 +271,24 @@ combo_with_super_undel AS (
         A._INSERTED_TIMESTAMP
     FROM
         {{ ref('silver__superfluid_actions') }} A
+        LEFT JOIN (
+            SELECT
+                DISTINCT tx_id,
+                lock_id
+            FROM
+                {{ ref('silver__locked_liquidity_actions_begin_unlock') }}
+        ) b
+        ON A.tx_id = b.tx_id
+        AND A.lock_id = b.lock_id
     WHERE
         msg_type = '/osmosis.superfluid.MsgSuperfluidUndelegate'
+        AND b.tx_id IS NULL
 ),
 tx_body AS (
     SELECT
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_type,
         msg_group,
         delegator_address,
@@ -307,6 +325,7 @@ SELECT
     A.chain_id,
     A.tx_id,
     A.tx_status,
+    A.tx_succeeded,
     A.msg_group,
     A.msg_type,
     COALESCE(

models/silver/silver__locked_liquidity_actions.yml

@@ -60,6 +60,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: MSG_GROUP
         description: "{{ doc('msg_group') }}"
         tests: 

models/silver/silver__locked_liquidity_actions_begin_unlock.sql

@@ -27,6 +27,7 @@ base_msg_atts AS (
         A.chain_id,
         A.tx_id,
         'SUCCEEDED' AS tx_status,
+        'TRUE' AS tx_succeeded,
         A.msg_group,
         CASE
             WHEN A.msg_type = 'begin_unlock' THEN A.msg_index
@@ -106,6 +107,7 @@ tx_msg_flat AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_group,
         msg_index,
         lock_id,
@@ -133,6 +135,7 @@ tx_msg_flat AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         msg_group,
         msg_index,
         lock_id,
@@ -146,6 +149,7 @@ FINAL AS (
         A.chain_id,
         A.tx_id,
         A.tx_status,
+        A.tx_succeeded,
         A.msg_group,
         A.msg_type,
         COALESCE(
@@ -218,6 +222,7 @@ SELECT
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     msg_group,
     msg_type,
     lock_id,

models/silver/silver__locked_liquidity_actions_begin_unlock.yml

@@ -60,6 +60,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: MSG_GROUP
         description: "{{ doc('msg_group') }}"
         tests: 

models/silver/silver__locked_liquidity_balances.sql

@@ -58,9 +58,39 @@ undel_base AS (
     WHERE
         msg_action_description IN (
             'unlock',
-            'unlock-undelegate',
-            'unpool'
+            'unlock-undelegate'
         )
+        AND (
+            unlock_time IS NOT NULL
+            OR msg_action = '/osmosis.superfluid.MsgSuperfluidUndelegate'
+        )
+        AND tx_id <> '1A2A80A7112995EA1A22D6EDBFB26AE7B863852A9E7F59779247F8928DA218D6'
+
+{% if is_incremental() %}
+AND block_timestamp :: DATE >=(
+    SELECT
+        DATEADD('day', -2, MAX(block_timestamp))
+    FROM
+        {{ this }})
+    {% endif %}
+),
+unpool_base AS (
+    SELECT
+        block_id,
+        block_timestamp,
+        locker_address AS address,
+        currency,
+        DECIMAL,
+        msg_action_description,
+        tx_id,
+        COALESCE(LAG(block_id) over (
+    ORDER BY
+        block_id), 1) AS lower_bound_unpool,
+        _inserted_timestamp
+    FROM
+        {{ ref('silver__locked_liquidity_actions') }}
+    WHERE
+        msg_action_description = 'unpool'
 
 {% if is_incremental() %}
 AND block_timestamp :: DATE >=(
@@ -73,21 +103,44 @@ AND block_timestamp :: DATE >=(
 unpool_lock_val AS (
     SELECT
         A.lock_id,
+        A.locker_address AS address,
         A.currency,
-        A.locker_address,
+        A.decimal,
         b.block_id,
-        b.tx_id
+        b.tx_id,
+        b.block_timestamp,
+        b._inserted_timestamp,
+        SUM(
+            CASE
+                WHEN A.msg_action_description IN (
+                    'initial lock',
+                    'add to position'
+                ) THEN 1
+                ELSE -1
+            END * amount
+        ) AS unpool_amount
     FROM
         {{ ref('silver__locked_liquidity_actions') }} A
-        JOIN undel_base b
-        ON b.msg_action_description = 'unpool'
-        AND A.locker_address = b.address
+        JOIN unpool_base b
+        ON A.locker_address = b.address
         AND A.currency = b.currency
         AND A.block_id < b.block_id
+        AND A.block_id > lower_bound_unpool
+        LEFT JOIN undel_base C
+        ON A.locker_address = C.address
+        AND A.lock_id = C.lock_id
     WHERE
-        A.lock_id IS NOT NULL qualify(ROW_NUMBER() over(PARTITION BY A.lock_id
-    ORDER BY
-        A.block_id DESC) = 1)
+        A.lock_id IS NOT NULL
+        AND C.tx_id IS NULL
+    GROUP BY
+        A.lock_id,
+        A.locker_address,
+        A.currency,
+        A.decimal,
+        b.block_id,
+        b.tx_id,
+        b.block_timestamp,
+        b._inserted_timestamp
 ),
 undel_bal AS (
     SELECT
@@ -97,20 +150,10 @@ undel_bal AS (
         SUM(COALESCE(amount, 0)) amount
     FROM
         {{ ref('silver__locked_liquidity_actions') }} A
-        LEFT JOIN unpool_lock_val C
-        ON A.locker_address = C.locker_address
-        AND A.currency = C.currency
-        AND A.block_id <= C.block_id
-        LEFT JOIN undel_base b
+        JOIN undel_base b
         ON A.lock_id = b.lock_id
-        LEFT JOIN undel_base bb
-        ON C.tx_id = bb.tx_id
     WHERE
-        (
-            bb.address IS NOT NULL
-            OR b.address IS NOT NULL
-        )
-        AND A.amount > 0
+        A.amount > 0
         AND A.msg_action_description IN (
             'initial lock',
             'add to position'
@@ -138,19 +181,26 @@ combine AS (
         block_timestamp,
         address,
         b.lock_id,
-        -1 * b.amount,
+        -1 * amount,
         b.currency,
         b.decimal,
         _inserted_timestamp
     FROM
         undel_base A
-        LEFT JOIN unpool_lock_val C
-        ON A.tx_id = C.tx_id
         JOIN undel_bal b
-        ON COALESCE(
-            A.lock_id,
-            C.lock_id
-        ) = b.lock_id
+        ON A.lock_id = b.lock_id
+    UNION ALL
+    SELECT
+        block_id,
+        block_timestamp,
+        address,
+        lock_id,
+        -1 * unpool_amount,
+        currency,
+        DECIMAL,
+        _inserted_timestamp
+    FROM
+        unpool_lock_val A
 )
 SELECT
     block_id,

models/silver/silver__locked_liquidity_transactions.sql

@@ -5,42 +5,22 @@
     cluster_by = ['_inserted_timestamp::DATE']
 ) }}
 
-SELECT
-    DISTINCT tx_id,
-    msg_group,
-    msg_sub_group,
-    CASE
-        WHEN msg_type = 'begin_unlock' THEN msg_index
-    END msg_index,
-    attribute_value :: NUMBER AS lock_id,
-    _inserted_timestamp,
-    concat_ws(
-        '-',
-        A.tx_id,
-        COALESCE(
-            A.msg_group,
-            -1
-        ),
-        COALESCE(
-            A.msg_sub_group,
-            -1
+WITH count_ids AS (
+
+    SELECT
+        tx_id,
+        msg_group,
+        msg_sub_group,
+        COUNT(
+            DISTINCT attribute_value
+        ) AS id_count
+    FROM
+        {{ ref('silver__msg_attributes') }} A
+    WHERE
+        attribute_key IN (
+            'period_lock_id',
+            'lock_id'
         )
-    ) AS _unique_key
-FROM
-    {{ ref('silver__msg_attributes') }} A
-WHERE
-    attribute_key IN (
-        'period_lock_id',
-        'lock_id'
-    )
-    AND A.tx_id NOT IN (
-        '523CBB1403A90A2A45A90ADFFC17F72100B99C286BD66DEDF22DD7F8A825127D',
-        'B26B72516A670B4FFD31F4F7853E65F7463F7A46BDE61800DC17A41F55AB87A3',
-        '34A6CEF2A87D6DB15DA1D7238D3A3BEABF8B4A1B460082B3C1F6C65DE5329CAC',
-        '504A0BD295DA63E28D55BC7C46575C6C49D9C2612D0AF118BA2A33A089A25A6D',
-        'B312127A7914D26444DA2C1104122F9CB7D3B50940F079544775C7EA4EE4981D',
-        '413991DF25FF3A217BA42D84D811CABC4A580F12FA9A8BC204E45F22529185CB'
-    )
 
 {% if is_incremental() %}
 AND _inserted_timestamp >= (
@@ -52,3 +32,94 @@ AND _inserted_timestamp >= (
         {{ this }}
 )
 {% endif %}
+GROUP BY
+    tx_id,
+    msg_group,
+    msg_sub_group
+),
+base AS (
+    SELECT
+        A.tx_id,
+        A.msg_group,
+        A.msg_sub_group,
+        CASE
+            WHEN id_count > 1 THEN msg_index
+        END msg_index_gp,
+        id_count,
+        _inserted_timestamp,
+        OBJECT_AGG(
+            CASE
+                WHEN attribute_key = 'action' THEN attribute_key || (
+                    SELECT
+                        UUID_STRING()
+                )
+                ELSE attribute_key
+            END :: STRING,
+            attribute_value :: variant
+        ) AS j,
+        COALESCE(
+            j :lock_id,
+            j :period_lock_id
+        ) :: INT AS lock_id
+    FROM
+        {{ ref('silver__msg_attributes') }} A
+        JOIN count_ids b
+        ON A.tx_id = b.tx_id
+        AND A.msg_group = b.msg_group
+        AND A.msg_sub_group = b.msg_sub_group
+    WHERE
+        attribute_key IN (
+            'period_lock_id',
+            'lock_id',
+            'action'
+        )
+        AND msg_type <> 'superfluid_undelegate'
+        AND A.tx_id NOT IN (
+            '523CBB1403A90A2A45A90ADFFC17F72100B99C286BD66DEDF22DD7F8A825127D',
+            'B26B72516A670B4FFD31F4F7853E65F7463F7A46BDE61800DC17A41F55AB87A3',
+            '34A6CEF2A87D6DB15DA1D7238D3A3BEABF8B4A1B460082B3C1F6C65DE5329CAC',
+            '504A0BD295DA63E28D55BC7C46575C6C49D9C2612D0AF118BA2A33A089A25A6D',
+            'B312127A7914D26444DA2C1104122F9CB7D3B50940F079544775C7EA4EE4981D',
+            '413991DF25FF3A217BA42D84D811CABC4A580F12FA9A8BC204E45F22529185CB'
+        )
+
+{% if is_incremental() %}
+AND _inserted_timestamp >= (
+    SELECT
+        MAX(
+            _inserted_timestamp
+        )
+    FROM
+        {{ this }}
+)
+{% endif %}
+GROUP BY
+    A.tx_id,
+    A.msg_group,
+    A.msg_sub_group,
+    msg_index_gp,
+    id_count,
+    _inserted_timestamp
+)
+SELECT
+    tx_id,
+    msg_group,
+    lock_id,
+    _inserted_timestamp,
+    concat_ws(
+        '-',
+        tx_id,
+        COALESCE(
+            msg_group,
+            -1
+        ),
+        lock_id
+    ) AS _unique_key
+FROM
+    base
+WHERE
+    (
+        j :: STRING LIKE '%action%'
+        OR id_count > 1
+    )
+    AND lock_id IS NOT NULL

models/silver/silver__locked_liquidity_transactions.yml

@@ -5,10 +5,7 @@ models:
     tests:
       - dbt_utils.unique_combination_of_columns:
           combination_of_columns:
-            - TX_ID
-            - MSG_GROUP
-            - MSG_SUB_GROUP
-            - LOCK_ID
+            - _UNIQUE_KEY
     columns:
       - name: TX_ID
         description: "{{ doc('tx_id') }}"
@@ -26,14 +23,6 @@ models:
               column_type_list:
                 - NUMBER
                 - FLOAT
-      - name: MSG_SUB_GROUP
-        description: "{{ doc('msg_sub_group') }}"
-        tests: 
-          - not_null
-          - dbt_expectations.expect_column_values_to_be_in_type_list:
-              column_type_list:
-                - NUMBER
-                - FLOAT
       - name: LOCK_ID
         description: "{{ doc('lock_id') }}"
         tests: 

models/silver/silver__msg_attributes.sql

@@ -12,6 +12,7 @@ SELECT
   blockchain,
   chain_id,
   tx_id,
+  tx_succeeded,
   msg_group,
   msg_sub_group,
   msg_index,

models/silver/silver__msg_attributes.yml

@@ -43,6 +43,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: MSG_GROUP
         description: "{{ doc('silver_msg_group') }}"
         tests: 

models/silver/silver__msgs.sql

@@ -15,6 +15,7 @@ WITH b AS (
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     INDEX AS msg_index,
     VALUE :type :: STRING AS msg_type,
     VALUE AS msg,
@@ -65,6 +66,7 @@ prefinal AS (
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     NULLIF(
       (conditional_true_event(is_action) over (PARTITION BY tx_id
       ORDER BY
@@ -118,6 +120,7 @@ SELECT
   chain_id,
   A.tx_id,
   tx_status,
+  tx_succeeded,
   msg_group,
   CASE
     WHEN msg_group IS NULL THEN NULL

models/silver/silver__msgs.yml

@@ -38,10 +38,11 @@ models:
         description: "{{ doc('tx_id') }}"
         tests: 
           - not_null
-          - dbt_expectations.expect_column_values_to_be_in_type_list:
-              column_type_list:
-                - STRING
-                - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: MSG_GROUP
         description: "{{ doc('silver_msg_group') }}"
         tests: 

models/silver/silver__staking.sql

@@ -261,6 +261,7 @@ add_dec AS (
         b.chain_id,
         A.tx_id,
         b.tx_status,
+        b.tx_succeeded,
         C.tx_caller_address,
         A.action,
         A.msg_group,
@@ -317,6 +318,7 @@ add_dec AS (
                 blockchain,
                 chain_id,
                 tx_status,
+                tx_succeeded,
                 _inserted_timestamp
             FROM
                 {{ ref('silver__transactions') }}
@@ -343,6 +345,7 @@ GROUP BY
     b.chain_id,
     A.tx_id,
     b.tx_status,
+    b.tx_succeeded,
     C.tx_caller_address,
     A.action,
     A.msg_group,
@@ -360,6 +363,7 @@ SELECT
     A.chain_id,
     A.tx_id,
     A.tx_status,
+    A.tx_succeeded,
     A.tx_caller_address,
     A.action,
     A.msg_group,

models/silver/silver__staking.yml

@@ -62,6 +62,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: TX_CALLER_ADDRESS
         description: "{{ doc('tx_caller_address') }}"
         tests: 

models/silver/silver__staking_rewards.sql

@@ -440,6 +440,7 @@ prefinal AS (
         b.chain_id,
         A.tx_id,
         b.tx_status,
+        b.tx_succeeded,
         C.tx_caller_address,
         A.action,
         A.msg_group,
@@ -491,6 +492,7 @@ prefinal AS (
                 blockchain,
                 chain_id,
                 tx_status,
+                tx_succeeded,
                 _inserted_timestamp
             FROM
                 {{ ref('silver__transactions') }} A
@@ -517,6 +519,7 @@ GROUP BY
     b.chain_id,
     A.tx_id,
     b.tx_status,
+    b.tx_succeeded,
     C.tx_caller_address,
     A.action,
     A.msg_group,
@@ -537,6 +540,7 @@ SELECT
     A.chain_id,
     A.tx_id,
     A.tx_status,
+    A.tx_succeeded,
     A.tx_caller_address,
     A.action,
     A.msg_group,

models/silver/silver__staking_rewards.yml

@@ -62,6 +62,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: TX_CALLER_ADDRESS
         description: "{{ doc('tx_caller_address') }}"
         tests: 

models/silver/silver__superfluid_actions.sql

@@ -12,6 +12,7 @@ SELECT
     chain_id,
     A.tx_id,
     A.tx_status,
+    A.tx_succeeded,
     A.msg_type,
     A.msg_group,
     msg :sender :: STRING AS delegator_address,
@@ -34,7 +35,7 @@ FROM
     {{ ref('silver__tx_body_msgs') }} A
     LEFT JOIN (
         SELECT
-            tx_id,
+            DISTINCT tx_id,
             msg_group,
             attribute_value AS lock_id
         FROM
@@ -70,6 +71,7 @@ WHERE
         '/osmosis.superfluid.MsgUnPoolWhitelistedPool'
     )
     AND tx_status = 'SUCCEEDED'
+    AND tx_succeeded = 'TRUE'
 
 {% if is_incremental() %}
 AND _inserted_timestamp >= (

models/silver/silver__superfluid_actions.yml

@@ -58,6 +58,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: MSG_TYPE
         description: "{{ doc('msg_type') }}"
         tests: 

models/silver/silver__superfluid_staking.sql

@@ -27,6 +27,7 @@ base_txn AS (
         A.chain_id,
         A.tx_id,
         A.tx_status,
+        A.tx_succeeded,
         A.msg_group,
         A.msg_type,
         A.msg_action_description,
@@ -115,6 +116,7 @@ SELECT
     A.tx_id,
     A.msg_group,
     A.tx_status,
+    A.tx_succeeded,
     {# msg_action_description, #}
     CASE
         msg_action_description

models/silver/silver__superfluid_staking.yml

@@ -60,10 +60,14 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: ACTION
         description: "{{ doc('action') }}"
         tests: 
-          - not_null
           - dbt_expectations.expect_column_values_to_be_in_type_list:
               column_type_list:
                 - STRING    

models/silver/silver__swaps.sql

@@ -27,6 +27,7 @@ swaps AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         tx_body,
         _inserted_timestamp,
         ROW_NUMBER() OVER (
@@ -45,6 +46,7 @@ swaps AS (
         key = '@type'
         AND VALUE :: STRING = '/osmosis.gamm.v1beta1.MsgSwapExactAmountIn'
         AND tx_status = 'SUCCEEDED'
+        AND tx_succeeded = 'TRUE'
 
 {% if is_incremental() %}
 AND t._inserted_timestamp >= (
@@ -65,6 +67,7 @@ pre_final AS (
         chain_id,
         tx_id,
         tx_status,
+        tx_succeeded,
         b.value,
         b.value :sender :: STRING AS trader,
         COALESCE(
@@ -244,6 +247,7 @@ pre_final2 AS (
         chain_id,
         p.tx_id,
         tx_status,
+        tx_succeeded,
         trader,
         f.from_amount,
         f.from_currency,
@@ -284,6 +288,7 @@ SELECT
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     trader,
     from_amount :: NUMBER AS from_amount,
     from_currency,

models/silver/silver__swaps.yml

@@ -58,6 +58,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: TRADER
         description: "{{ doc('trader') }}"
         tests: 

models/silver/silver__transactions.sql

@@ -18,6 +18,10 @@ SELECT
     WHEN tx :tx_result :code :: INT = 0 THEN 'SUCCEEDED'
     ELSE 'FAILED'
   END AS tx_status,
+  CASE
+    WHEN tx :tx_result :code :: INT = 0 THEN 'TRUE'
+    ELSE 'FALSE'
+  END AS tx_succeeded,
   tx :tx_result :code :: INT tx_code,
   tx :tx_result :events AS msgs,
   tx :auth_info AS auth_info,

models/silver/silver__transactions.yml

@@ -72,6 +72,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: TX_CODE
         description: "{{ doc('tx_code') }}"
         tests: 

models/silver/silver__transfers.sql

@@ -276,6 +276,7 @@ SELECT
     chain_id,
     r.tx_id,
     tx_status,
+    t.tx_succeeded,
     'IBC_TRANSFER_OUT' AS transfer_type,
     r.msg_index,
     sender,
@@ -323,6 +324,7 @@ SELECT
     chain_id,
     r.tx_id,
     tx_status,
+    t.tx_succeeded,
     'OSMOSIS' AS transfer_type,
     r.msg_index,
     sender,
@@ -371,10 +373,11 @@ SELECT
     m.chain_id,
     s.tx_id,
     tx_status,
+    m.tx_succeeded,
     'IBC_TRANSFER_IN' AS transfer_type,
     m.msg_index,
     TRY_PARSE_JSON(attribute_value) :sender :: STRING AS sender,
-    C.amount,
+    C.amount :: NUMBER AS amount,
     C.currency,
     raw_metadata [1] :exponent :: INTEGER AS DECIMAL,
     TRY_PARSE_JSON(attribute_value) :receiver :: STRING AS receiver,

models/silver/silver__transfers.yml

@@ -59,6 +59,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: TRANSFER_TYPE
         description: "{{ doc('transfer_type') }}"
         tests: 

models/silver/silver__tx_body_msgs.sql

@@ -14,6 +14,7 @@ WITH b AS (
     chain_id,
     tx_id,
     tx_status,
+    tx_succeeded,
     INDEX AS msg_group,
     VALUE :"@type" :: STRING AS msg_type,
     VALUE AS msg,
@@ -43,6 +44,7 @@ SELECT
   chain_id,
   tx_id,
   tx_status,
+  tx_succeeded,
   msg_group,
   msg_type,
   msg,

models/silver/silver__tx_body_msgs.yml

@@ -42,6 +42,11 @@ models:
               column_type_list:
                 - STRING
                 - VARCHAR
+      - name: TX_SUCCEEDED
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_set:
+              value_set: ['TRUE', 'FALSE']
       - name: MSG_GROUP
         description: "{{ doc('msg_group') }}"
         tests: