From db1c4c7c94a0cc20c3796a44059966323783a9d4 Mon Sep 17 00:00:00 2001 From: Koen van der Veen Date: Mon, 7 Oct 2024 11:10:09 +0200 Subject: [PATCH] add setting the passed signing key in worker --- packages/syft/src/syft/service/queue/queue.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/packages/syft/src/syft/service/queue/queue.py b/packages/syft/src/syft/service/queue/queue.py index 2cd86d7ae5f..31af7d11060 100644 --- a/packages/syft/src/syft/service/queue/queue.py +++ b/packages/syft/src/syft/service/queue/queue.py @@ -192,6 +192,10 @@ def handle_message_multiprocessing( deployment_type=worker_settings.deployment_type, ) + # otherwise it reads it from env, resulting in the wrong credentials + worker.id = worker_settings.id + worker.signing_key = worker_settings.signing_key + # Set monitor thread for this job. monitor_thread = MonitorThread(queue_item, worker, credentials) monitor_thread.start()