Skip to content

Commit

Permalink
fix typo in keras.distribution.initialize (proceed_id -> process_id) (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
RobinKa authored Mar 10, 2024
1 parent 04eca3a commit 404e8f3
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions keras/distribution/distribution_lib.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ def list_devices(device_type=None):


@keras_export("keras.distribution.initialize")
def initialize(job_addresses=None, num_processes=None, proceed_id=None):
def initialize(job_addresses=None, num_processes=None, process_id=None):
"""Initialize the distribution system for multi-host/process setting.
Calling `initialize` will prepare the backend for execution on multi-host
Expand Down Expand Up @@ -126,9 +126,9 @@ def initialize(job_addresses=None, num_processes=None, proceed_id=None):
and "KERAS_DISTRIBUTION_NUM_PROCESSES" in os.environ
):
num_processes = int(os.environ["KERAS_DISTRIBUTION_NUM_PROCESSES"])
if proceed_id is None and "KERAS_DISTRIBUTION_PROCESS_ID" in os.environ:
proceed_id = int(os.environ["KERAS_DISTRIBUTION_PROCESS_ID"])
distribution_lib.initialize(job_addresses, num_processes, proceed_id)
if process_id is None and "KERAS_DISTRIBUTION_PROCESS_ID" in os.environ:
process_id = int(os.environ["KERAS_DISTRIBUTION_PROCESS_ID"])
distribution_lib.initialize(job_addresses, num_processes, process_id)


@keras_export("keras.distribution.DeviceMesh")
Expand Down

0 comments on commit 404e8f3

Please sign in to comment.