Skip to content

Commit b1d60f6

Browse files
authored
fix(tasks) Add rpc_secret to taskworker (#593)
1 parent 1d314a0 commit b1d60f6

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

src/launchpad/worker/app.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,4 +102,10 @@ def producer_factory(topic: str) -> KafkaProducer:
102102
metrics_class=TaskworkerMetricsBackend(),
103103
)
104104

105+
app.set_config(
106+
{
107+
"rpc_secret": os.getenv("TASKWORKER_SHARED_SECRET", None),
108+
}
109+
)
110+
105111
app.set_modules(["launchpad.worker.tasks"])

0 commit comments

Comments
 (0)