Skip to content

Commit f0dd29e

Browse files
committed
[Deploy] Nit.
1 parent 3a03471 commit f0dd29e

1 file changed

Lines changed: 2 additions & 6 deletions

File tree

python/fedml/computing/scheduler/model_scheduler/master_job_runner.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -369,12 +369,8 @@ def process_deployment_result_message(self, topic=None, payload=None):
369369
"""
370370
When all the devices have finished the add / delete / update operation
371371
"""
372-
# Generate one unified inference api
373-
# Note that here we use the gateway port instead of the inference port that is used by the slave device
374-
model_config_parameters = request_json["parameters"]
375-
inference_port = model_config_parameters.get("server_internal_port",
376-
ServerConstants.MODEL_INFERENCE_DEFAULT_PORT)
377-
inference_port_external = model_config_parameters.get("server_external_port", inference_port)
372+
inference_port_external = os.environ.get(ServerConstants.ENV_MASTER_INFERENCE_PORT_KEY,
373+
ServerConstants.MODEL_INFERENCE_DEFAULT_PORT)
378374
ip = GeneralConstants.get_ip_address(request_json)
379375

380376
if ip.startswith("http://") or ip.startswith("https://"):

0 commit comments

Comments
 (0)