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()