Skip to content

Commit 8b795db

Browse files
committed
feat: pass Kafka env vars to livepeer runner subprocess
Add KAFKA_BOOTSTRAP_SERVERS, KAFKA_TOPIC, KAFKA_SASL_USERNAME, and KAFKA_SASL_PASSWORD to the env allowlist so the inner runner's kafka_publisher can initialize and publish stream lifecycle events. Signed-off-by: emranemran <emran@livepeer.org> Signed-off-by: emranemran <emran.mah@gmail.com>
1 parent a0f0322 commit 8b795db

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

src/scope/cloud/livepeer_fal_app.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -381,6 +381,11 @@ def setup(self):
381381
"DAYDREAM_SCOPE_BUNDLED_PLUGINS_FILE",
382382
"LIVEPEER_DEBUG",
383383
"UV_CACHE_DIR",
384+
# Kafka (for scope.server.kafka_publisher in the runner subprocess)
385+
"KAFKA_BOOTSTRAP_SERVERS",
386+
"KAFKA_TOPIC",
387+
"KAFKA_SASL_USERNAME",
388+
"KAFKA_SASL_PASSWORD",
384389
]
385390
runner_env = {k: os.environ[k] for k in env_allowlist if k in os.environ}
386391
runner_env.setdefault("UV_CACHE_DIR", "/tmp/uv-cache")

0 commit comments

Comments
 (0)