diff --git a/bsky-activity.py b/bsky-activity.py
index 5978d1a..2ad4ba1 100755
--- a/bsky-activity.py
+++ b/bsky-activity.py
@@ -35,7 +35,7 @@ other_allowlist = set([
 ])
 
 async def bsky_activity():
-    relay_url = 'ws://localhost:6008/subscribe'
+    relay_url = 'wss://jetstream1.us-west.bsky.network/subscribe'
 
     sys.stdout.write(f'opening websocket connection to {relay_url}\n')
     sys.stdout.flush()
diff --git a/cmd/bsky-langs/main.go b/cmd/bsky-langs/main.go
index 9722f53..a8b9da8 100644
--- a/cmd/bsky-langs/main.go
+++ b/cmd/bsky-langs/main.go
@@ -10,7 +10,7 @@ import (
 	"github.com/gorilla/websocket"
 )
 
-const JetstreamUrl = `ws://localhost:6008/subscribe?wantedCollections=app.bsky.feed.post`
+const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe?wantedCollections=app.bsky.feed.post`
 
 func main() {
 	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
diff --git a/cmd/bsky-users/main.go b/cmd/bsky-users/main.go
index 6a8ea39..5483b26 100644
--- a/cmd/bsky-users/main.go
+++ b/cmd/bsky-users/main.go
@@ -39,9 +39,7 @@ var AppBskyAllowlist = map[string]bool{
 	"chat.bsky.actor.declaration": true,
 }
 
-// const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe`
-
-const JetstreamUrl = `ws://localhost:6008/subscribe` // TODO(ejd): attach a reconnect cursor
+const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe` // TODO(ejd): attach a reconnect cursor
 
 const userTimestampUpdate = `insert into users (did, ts) values (?, ?) on conflict (did) do update set ts = ?`