Sort out differing db names

el.py

@@ -62,10 +62,10 @@ def load_data():
 
     if args.prod:
         spinner_text = "🦆☁️  Loading data into MotherDuck..."
-        connection = "md:github_archive"
+        connection = "md:octocatalog"
     else:
         spinner_text = "🦆💾 Loading data into DuckDB..."
-        connection = "./reports/github_archive.db"
+        connection = "./reports/octocatalog.db"
 
     spinner = Halo(text=spinner_text, spinner="dots")
     spinner.start()

models/marts/push_events.sql

@@ -0,0 +1,30 @@
+with
+
+push_events as (
+
+    select * from {{ ref('stg_events') }}
+
+    where event_type in ('PushEvent')
+
+),
+
+unnest_json as (
+
+    select
+        event_id,
+        actor_id,
+        payload,
+        repo_id,
+        repo_name,
+        actor_login,
+        event_created_at,
+        payload ->> '$.push_id' as push_id,
+        payload ->> '$.size' as push_size,
+        payload ->> '$.distinct_size' as push_distinct_size,
+        payload -> '$.commits' as push_commits,
+
+    from push_events
+
+)
+
+select * from unnest_json

models/staging/github/_sources.yml

@@ -1,6 +1,5 @@
 sources:
-  - name: github
-    database: github_archive
+  - name: octocatalog
     schema: raw
     tables:
       - name: github_events

models/staging/github/stg_events.sql

@@ -2,7 +2,7 @@ with
 
 source as (
 
-    select * from {{ source('github', 'github_events') }}
+    select * from {{ source('octocatalog', 'github_events') }}
 
 ),
 

profiles.yml

@@ -2,7 +2,7 @@ octocatalog:
   outputs:
     dev:
       type: duckdb
-      path: ./reports/github_archive.db
+      path: ./reports/octocatalog.db
     prod:
       type: duckdb
       path: md:octocatalog