Merge branch 'dev' into fix_status_l0

OpenMined · Oct 8, 2024 · 69c35a2 · 69c35a2
2 parents 9ef5386 + 46c29bc
commit 69c35a2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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()