+3 -3

Makefile

··· 9 run: 10 uv run -- dotenv run -- gunicorn 11 12 - .PHONY: ingest 13 - ingest: 14 - uv run -- src/ingest.py

··· 9 run: 10 uv run -- dotenv run -- gunicorn 11 12 + .PHONY: ingestor 13 + ingestor: 14 + uv run -- ingestor

+1 -1

dist/ligoatingestor.service

··· 3 After = ligoat.service 4 5 [Service] 6 - ExecStart = uv run -- src/ingest.py 7 Type = simple 8 Restart = always 9 RestartSec = 5s

··· 3 After = ligoat.service 4 5 [Service] 6 + ExecStart = uv run -- ingestor 7 Type = simple 8 Restart = always 9 RestartSec = 5s

+2 -1

src/ingest.py ingestor/__main__.py

··· 10 11 12 async def ingest_jetstream(config: dict[str, str | None]): 13 - socket = f"wss://{config['JETSTREAM_URL']}/subscribe" 0 14 socket += "?wantedCollections=at.ligo.*" 15 logger.info(f"connecting to {socket}") 16 async with aiohttp.ClientSession() as session:

··· 10 11 12 async def ingest_jetstream(config: dict[str, str | None]): 13 + base = config.get("JETSTREAM_URL", "jetstream1.us-east.bsky.network") 14 + socket = f"wss://{base}/subscribe" 15 socket += "?wantedCollections=at.ligo.*" 16 logger.info(f"connecting to {socket}") 17 async with aiohttp.ClientSession() as session: