Job name should be picked based on the cluster_spec
PiperOrigin-RevId: 211833041
This commit is contained in:
parent
b9310932ce
commit
9638524520
@ -229,6 +229,10 @@ class TPUClusterResolver(ClusterResolver):
|
||||
def get_master(self):
|
||||
return self.master()
|
||||
|
||||
def get_job_name(self):
|
||||
if self._shouldResolve():
|
||||
return self._job_name
|
||||
|
||||
def cluster_spec(self):
|
||||
"""Returns a ClusterSpec object based on the latest TPU information.
|
||||
|
||||
|
@ -310,7 +310,8 @@ class TPUStrategy(one_device_strategy.OneDeviceStrategy):
|
||||
def get_host_cpu_device(self, host_id):
|
||||
if self._tpu_cluster_resolver.get_master() in ('', 'local'):
|
||||
return '/replica:0/task:0/device:CPU:0'
|
||||
return '/job:tpu_worker/task:%d/device:CPU:0' % (host_id,)
|
||||
job_name = self._tpu_cluster_resolver.get_job_name() or 'tpu_worker'
|
||||
return '/job:%s/task:%d/device:CPU:0' % (job_name, host_id)
|
||||
|
||||
def configure(self,
|
||||
session_config=None,
|
||||
|
Loading…
Reference in New Issue
Block a user