Home
last modified time | relevance | path

Searched defs:task_type (Results 1 – 25 of 51) sorted by relevance

123

/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dcluster_resolver.py111 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
131 task_type=None, argument
188 def task_type(self): member in ClusterResolver
278 def task_type(self, task_type): member in ClusterResolver
320 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
345 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
369 def task_type(self): member in SimpleClusterResolver
377 def task_type(self, task_type): argument
389 task_type=None, argument
569 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
[all …]
Dtfconfig_cluster_resolver.py81 task_type=None, argument
102 def task_type(self): member in TFConfigClusterResolver
118 def task_type(self, task_type): argument
141 task_type=None, argument
160 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
Dgce_cluster_resolver.py69 task_type='worker', argument
170 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
184 def task_type(self): member in GCEClusterResolver
192 def task_type(self, task_type): argument
Dsagemaker_cluster_resolver.py91 task_type=None, argument
112 def task_type(self): member in SageMakerClusterResolver
128 def task_type(self, task_type): argument
150 def num_accelerators(self, task_type=None, task_id=None, config_proto=None): argument
167 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
Dslurm_cluster_resolver.py369 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
392 task_type=None, argument
/external/tensorflow/tensorflow/python/distribute/
Dmulti_worker_util.py45 def task_count(cluster_spec, task_type): argument
53 task_type, argument
108 def is_chief(cluster_spec=None, task_type=None, task_id=None): argument
148 def collective_leader(cluster_spec, task_type, task_id): argument
207 def worker_count(cluster_spec, task_type): argument
228 def id_in_cluster(cluster_spec, task_type, task_id): argument
Dmulti_process_runner.py255 def _continuously_readline_from_sub(self, pipe_r, task_type, task_id): argument
269 task_type, argument
418 task_type, argument
477 def get_process_id(self, task_type, task_id): argument
483 def get_process_exit_code(self, task_type, task_id): argument
501 def process_exists(self, task_type, task_id): argument
680 def terminate(self, task_type, task_id): argument
770 def _message_checking_func(self, task_type, task_id): argument
1010 def _pool_runner_worker(task_type, task_id, initializer, conn): argument
1039 def _run_contained(task_type, task_id, fn, args, kwargs): argument
[all …]
Ddistribute_coordinator.py111 task_type, argument
282 def task_type(self): member in _WorkerContext
325 task_type, argument
359 def _split_cluster_for_evaluator(cluster_spec, task_type): argument
382 task_type=None, argument
526 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument
633 task_type=None, argument
Dparameter_server_strategy_test.py70 task_type=None, argument
111 def _get_test_objects(self, task_type, task_id, num_gpus): argument
119 def _test_device_assignment_distributed(self, task_type, task_id, num_gpus): argument
219 self, task_type, task_id, num_gpus): argument
368 def _test_simple_increment(self, task_type, task_id, num_gpus): argument
432 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
519 task_type, argument
Dcollective_all_reduce_strategy_test.py72 task_type=None, argument
111 task_type, argument
138 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
211 def _test_variable_initialization(self, task_type, task_id, num_gpus): argument
239 task_type, argument
369 def _worker_fn(task_type, task_id, required_gpus): argument
Dmulti_worker_test_base.py286 def kill_task(self, task_type, task_id): argument
301 def start_task(self, task_type, task_id): argument
511 def _run_client(self, client_fn, task_type, task_id, num_gpus, eager_mode, argument
672 def _run_task_in_thread(self, task_fn, cluster_spec, task_type, task_id, argument
734 def _run_task_in_process(self, cmd_args, cluster_spec, task_type, task_id): argument
/external/tensorflow/tensorflow/python/keras/distribute/
Ddistribute_coordinator_utils.py76 task_type, argument
247 def task_type(self): member in _WorkerContext
290 task_type, argument
324 def _split_cluster_for_evaluator(cluster_spec, task_type): argument
346 task_type=None, argument
416 task_type, task_id): argument
449 task_type=None, argument
/external/cronet/stable/base/task/sequence_manager/
Dtasks.cc117 TaskType task_type, in PostedTask()
134 TaskType task_type, in PostedTask()
Dtasks.h65 TaskType task_type = kTaskTypeNone; member
136 TaskType task_type; member
/external/cronet/tot/base/task/sequence_manager/
Dtasks.cc117 TaskType task_type, in PostedTask()
134 TaskType task_type, in PostedTask()
Dtasks.h65 TaskType task_type = kTaskTypeNone; member
136 TaskType task_type; member
/external/chromiumos-config/proto/chromiumos/test/api/
Dtrv2_dynamic_updates.proto33 TaskType task_type = 1; field
37 TaskType task_type = 1; field
/external/googleapis/google/cloud/osconfig/agentendpoint/v1beta/
Dagentendpoint.proto116 TaskType task_type = 3 [(google.api.field_behavior) = REQUIRED]; field
151 TaskType task_type = 3 [(google.api.field_behavior) = REQUIRED]; field
/external/cronet/tot/base/android/
Dmemory_purge_manager_android.cc20 base::BindOnce([](base::MemoryReductionTaskContext task_type) { in JNI_MemoryPurgeManager_PostDelayedPurgeTaskOnUiThread()
/external/cronet/stable/base/android/
Dmemory_purge_manager_android.cc20 base::BindOnce([](base::MemoryReductionTaskContext task_type) { in JNI_MemoryPurgeManager_PostDelayedPurgeTaskOnUiThread()
/external/googleapis/google/cloud/osconfig/agentendpoint/v1/
Dagentendpoint.proto114 TaskType task_type = 3 [(google.api.field_behavior) = REQUIRED]; field
152 TaskType task_type = 3 [(google.api.field_behavior) = REQUIRED]; field
/external/cronet/tot/base/task/sequence_manager/test/
Dfake_task.cc12 FakeTask::FakeTask(TaskType task_type) in FakeTask()
/external/cronet/stable/base/task/sequence_manager/test/
Dfake_task.cc12 FakeTask::FakeTask(TaskType task_type) in FakeTask()
/external/libchrome/base/task/sequence_manager/
Dtask_queue.h70 int task_type; member
143 int task_type() const { return task_type_; } in task_type() function
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/tpu/
Dtpu_cluster_resolver.py229 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
344 task_type=None, argument

123