Wait between the pulls, restart on failure

heussd · heussd · commit 2eda46245b4c · 2025-11-07T11:03:55.000Z
diff --git a/.devcontainer/python/devcontainer.json b/.devcontainer/python/devcontainer.json
@@ -37,7 +37,7 @@
         }
     },
     "containerEnv": {
-        "NATS_URL": "http://nats-server:4222"
+        "NATS_URL": "nats://nats-server:4222"
     },
     "shutdownAction": "stopCompose"
 }
diff --git a/.gitignore b/.gitignore
@@ -12,3 +12,4 @@ urls-secondary.txt
 prom-storage
 __debug_*
 .env
+*.pyc
diff --git a/compose.yml b/compose.yml
@@ -68,6 +68,7 @@ services:
     nats-indexer:
         deploy:
             replicas: 1
+        restart: always
         image: ghcr.io/heussd/nats-news-analysis/nats-indexer:latest
         environment:
             - 'NATS_URL=nats-server:4222'
diff --git a/python/nats-indexer.py b/python/nats-indexer.py
@@ -44,7 +44,8 @@ async def run():
             for msg in msgs:
                 await msg.ack()
         except asyncio.TimeoutError:
-            print("No new messages, waiting...")
+            print("No new messages, waiting 10 secs...")
+            await asyncio.sleep(10)
             continue
 
 

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@`
`37`	`37`	`}`
`38`	`38`	`},`
`39`	`39`	`"containerEnv": {`
`40`		`- "NATS_URL": "http://nats-server:4222"`
	`40`	`+ "NATS_URL": "nats://nats-server:4222"`
`41`	`41`	`},`
`42`	`42`	`"shutdownAction": "stopCompose"`
`43`	`43`	`}`