[DRAFT] Build Enriched Traces & Transactions + Aggregation Tables

src/op_analytics/datapipeline/models/code/enriched_traces.py

@@ -0,0 +1,29 @@
+import duckdb
+
+from op_analytics.datapipeline.models.compute.querybuilder import TemplatedSQLQuery
+from op_analytics.datapipeline.models.compute.registry import register_model
+from op_analytics.datapipeline.models.compute.types import NamedRelations
+
+
+@register_model(
+    input_datasets=["ingestion/traces_v1", "ingestion/transactions_v1", "ingestion/blocks_v1"],
+    expected_outputs=["enriched_traces_v1"],
+    auxiliary_views=[
+        TemplatedSQLQuery(
+            template_name="transaction_fees",
+            context={},
+        ),
+        TemplatedSQLQuery(
+            template_name="enriched_transactions",
+            context={},
+        ),
+        TemplatedSQLQuery(
+            template_name="enriched_traces",
+            context={},
+        ),
+    ],
+)
+def daily_address_summary(duckdb_client: duckdb.DuckDBPyConnection) -> NamedRelations:
+    return {
+        "enriched_traces_v1": duckdb_client.view("enriched_traces"),
+    }

src/op_analytics/datapipeline/models/code/enriched_transaction.py

@@ -0,0 +1,25 @@
+import duckdb
+
+from op_analytics.datapipeline.models.compute.querybuilder import TemplatedSQLQuery
+from op_analytics.datapipeline.models.compute.registry import register_model
+from op_analytics.datapipeline.models.compute.types import NamedRelations
+
+
+@register_model(
+    input_datasets=["ingestion/transactions_v1", "ingestion/blocks_v1"],
+    expected_outputs=["enriched_transactions_v1"],
+    auxiliary_views=[
+        TemplatedSQLQuery(
+            template_name="transaction_fees",
+            context={},
+        ),
+        TemplatedSQLQuery(
+            template_name="enriched_transactions",
+            context={},
+        ),
+    ],
+)
+def daily_address_summary(duckdb_client: duckdb.DuckDBPyConnection) -> NamedRelations:
+    return {
+        "enriched_transactions_v1": duckdb_client.view("enriched_transactions"),
+    }