Merge pull request #89 from jakthom/pipelined

Flip jetstream posts per minute to piped sql syntax
jakthom · Nov 21, 2024 · d87a961 · d87a961
2 parents 39031ba + 5416a1b
commit d87a961
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/hercules-packages/bluesky/1.0.yaml b/hercules-packages/bluesky/1.0.yaml
@@ -1,6 +1,10 @@
 name: bluesky
 version: 1.0
 
+extensions:
+  community:
+    - name: psql
+
 sources:
   - name: profile
     type: sql
@@ -143,7 +147,7 @@ metrics:
 
     - name: jetstream_posts_per_minute_bucket
       help: Quantiles of posts per minute
-      sql: select date_trunc('minute', make_timestamp(time_us)), count(*) from jetstream where commit.collection = 'app.bsky.feed.post' and commit.operation = 'create' group by 1;
+      sql: from jetstream |> select date_trunc('minute', make_timestamp(time_us)), count(*) where commit.collection = 'app.bsky.feed.post' and commit.operation = 'create' group by 1;
       objectives:
         - 0.5
         - 0.9