[bugfix] Properly re-serialize payload for deployment delete request

FedML-AI · Feb 13, 2025 · 74a6637 · 74a6637
1 parent a4ddd5c
commit 74a6637
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/python/fedml/computing/scheduler/model_scheduler/master_job_runner.py b/python/fedml/computing/scheduler/model_scheduler/master_job_runner.py
@@ -287,8 +287,9 @@ def process_deployment_result_message(self, topic=None, payload=None):
                 model_config["model_version"] = payload_json["model_version"]
                 # add model_config to the payload for the delete request
                 payload_json["model_config"] = model_config
-                model_msg_object = FedMLModelMsgObject(topic, payload)
-                self.send_deployment_delete_request_to_edges(payload, model_msg_object, message_center=self.message_center)
+                payload_for_del_deploy = json.dumps(payload_json)
+                model_msg_object = FedMLModelMsgObject(topic, payload_for_del_deploy)
+                self.send_deployment_delete_request_to_edges(payload_for_del_deploy, model_msg_object, message_center=self.message_center)
                 return
 
             # Failure handler, send the rollback message to the worker devices only if it has not been rollback