From e9520bd29547023858a8109a72dbc60621cf3d78 Mon Sep 17 00:00:00 2001
From: Kian-Tat Lim <ktl@slac.stanford.edu>
Date: Thu, 16 Mar 2023 22:38:41 -0300
Subject: [PATCH] Get bucket_topic from env var.

---
 Dockerfile.activator          | 1 +
 python/activator/activator.py | 3 +--
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/Dockerfile.activator b/Dockerfile.activator
index eff3fbeb..24b50a66 100644
--- a/Dockerfile.activator
+++ b/Dockerfile.activator
@@ -9,6 +9,7 @@ ARG PORT
 ARG CALIB_REPO
 ARG IMAGE_BUCKET
 ARG IMAGE_TIMEOUT
+ARG BUCKET_TOPIC
 WORKDIR $APP_HOME
 COPY python/activator activator/
 COPY pipelines pipelines/
diff --git a/python/activator/activator.py b/python/activator/activator.py
index 38a46598..44cf45d6 100644
--- a/python/activator/activator.py
+++ b/python/activator/activator.py
@@ -65,8 +65,7 @@
 # Kafka group; must be worker-unique to keep workers from "stealing" messages for others.
 kafka_group_id = str(uuid.uuid4())
 # The topic on which to listen to updates to image_bucket
-# bucket_topic = f"{instrument_name}-image"
-bucket_topic = "rubin-prompt-processing"
+bucket_topic = os.environ.get("BUCKET_TOPIC", "rubin-prompt-processing")
 
 setup_usdf_logger(
     labels={"instrument": instrument_name},