From d5b6855375cd335e2fee33d10c4f8af4e5f5e327 Mon Sep 17 00:00:00 2001 From: Kevin Donahue Date: Sun, 7 Jul 2024 10:43:08 -0400 Subject: [PATCH] use smaller rabbitmq image --- docker-compose.yml | 3 +-- pp/pp/main.py | 5 +---- pp/pp/prediction.py | 2 +- 3 files changed, 3 insertions(+), 7 deletions(-) diff --git a/docker-compose.yml b/docker-compose.yml index 7889a73..c59f628 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -7,7 +7,7 @@ services: - "6379:6379" rabbitmq: - image: "rabbitmq:management" + image: "rabbitmq:3-management-alpine" ports: - "5672:5672" - "15672:15672" @@ -60,5 +60,4 @@ services: volumes: open-meteo-data: - external: true diff --git a/pp/pp/main.py b/pp/pp/main.py index b12c0fa..92fc221 100644 --- a/pp/pp/main.py +++ b/pp/pp/main.py @@ -14,10 +14,7 @@ async def main(): - """initializes process of publishing sky brightness - - n.b. with 122 res 0 cells on 2016 macbook, this will publish at a rate of 1.4m/s - """ + """initializes process of publishing sky brightness messages to the prediction queue.""" try: connection = pika.BlockingConnection(pika.ConnectionParameters(rabbitmq_host)) diff --git a/pp/pp/prediction.py b/pp/pp/prediction.py index f315c25..9df99ad 100644 --- a/pp/pp/prediction.py +++ b/pp/pp/prediction.py @@ -51,7 +51,7 @@ async def create_brightness_message(client: httpx.AsyncClient, h3_lat: float, h3 async def publish_cell_brightness(client: httpx.AsyncClient, h3_coords: Tuple[float, float], channel: Channel): - """create and publish sky brightness at given h3 cell coords.""" + """request and publish sky brightness at given h3 cell coords.""" try: lat, lon = h3_coords