Home
last modified time | relevance | path

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

12

/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dcluster_resolver.py115 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
135 task_type=None, argument
192 def task_type(self): member in ClusterResolver
282 def task_type(self, task_type): member in ClusterResolver
324 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
349 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
373 def task_type(self): member in SimpleClusterResolver
381 def task_type(self, task_type): argument
393 task_type=None, argument
573 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
[all …]
Dtfconfig_cluster_resolver.py85 task_type=None, argument
106 def task_type(self): member in TFConfigClusterResolver
122 def task_type(self, task_type): argument
145 task_type=None, argument
164 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
Dgce_cluster_resolver.py73 task_type='worker', argument
174 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
188 def task_type(self): member in GCEClusterResolver
196 def task_type(self, task_type): argument
Dsagemaker_cluster_resolver.py95 task_type=None, argument
116 def task_type(self): member in SageMakerClusterResolver
132 def task_type(self, task_type): argument
154 def num_accelerators(self, task_type=None, task_id=None, config_proto=None): argument
171 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
Dslurm_cluster_resolver.py373 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
396 task_type=None, argument
Dkubernetes_cluster_resolver.py121 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
Dcluster_resolver_test.py39 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
/external/tensorflow/tensorflow/python/distribute/
Dmulti_worker_util.py49 def task_count(cluster_spec, task_type): argument
57 task_type, argument
112 def is_chief(cluster_spec=None, task_type=None, task_id=None): argument
152 def collective_leader(cluster_spec, task_type, task_id): argument
186 def worker_count(cluster_spec, task_type): argument
207 def id_in_cluster(cluster_spec, task_type, task_id): argument
Dmulti_process_runner.py251 def _continuously_readline_from_sub(self, pipe_r, task_type, task_id): argument
265 task_type, argument
404 task_type, argument
463 def get_process_id(self, task_type, task_id): argument
469 def get_process_exit_code(self, task_type, task_id): argument
487 def process_exists(self, task_type, task_id): argument
666 def terminate(self, task_type, task_id): argument
753 def _message_checking_func(self, task_type, task_id): argument
987 def _pool_runner_worker(task_type, task_id, initializer, conn): argument
1016 def _run_contained(task_type, task_id, fn, args, kwargs): argument
[all …]
Ddistribute_coordinator.py115 task_type, argument
286 def task_type(self): member in _WorkerContext
329 task_type, argument
363 def _split_cluster_for_evaluator(cluster_spec, task_type): argument
386 task_type=None, argument
530 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument
637 task_type=None, argument
Dparameter_server_strategy_test.py74 task_type=None, argument
115 def _get_test_objects(self, task_type, task_id, num_gpus): argument
123 def _test_device_assignment_distributed(self, task_type, task_id, num_gpus): argument
223 self, task_type, task_id, num_gpus): argument
372 def _test_simple_increment(self, task_type, task_id, num_gpus): argument
436 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
523 task_type, argument
Dcollective_all_reduce_strategy_test.py70 task_type=None, argument
105 def _get_test_object(self, task_type, task_id, num_gpus=0): argument
113 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
185 def _test_variable_initialization(self, task_type, task_id, num_gpus): argument
214 task_type, argument
348 def _worker_fn(task_type, task_id, required_gpus): argument
Dmulti_worker_test_base.py311 def kill_task(self, task_type, task_id): argument
326 def start_task(self, task_type, task_id): argument
533 def _run_client(self, client_fn, task_type, task_id, num_gpus, eager_mode, argument
694 def _run_task_in_thread(self, task_fn, cluster_spec, task_type, task_id, argument
756 def _run_task_in_process(self, cmd_args, cluster_spec, task_type, task_id): argument
Ddistribute_coordinator_test.py111 task_type=None, argument
412 task_type=None, argument
802 task_type=None, argument
918 task_type=None, argument
Destimator_training.py59 def _get_global_id(cluster_spec, task_type, task_id, chief_task_type): argument
Dcollective_all_reduce_strategy.py658 task_type=None, argument
Dparameter_server_strategy.py597 task_type=None, argument
Dmirrored_strategy.py676 task_type=None, argument
/external/llvm-project/openmp/runtime/test/ompt/tasks/
Dtask_types_serialized.c12 int task_type; in print_task_type() local
/external/tensorflow/tensorflow/python/keras/integration_test/
Dmulti_worker_tutorial_test.py36 def _is_chief(task_type, task_id): argument
54 def write_filepath(filepath, task_type, task_id): argument
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/tpu/
Dtpu_cluster_resolver.py230 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
345 task_type=None, argument
/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
Dtask_queue.cc61 int task_type) in PostedTask()
/external/tensorflow/tensorflow/python/distribute/v1/
Dcross_device_ops_test.py458 task_type, argument
529 task_type, argument
668 task_type, argument
/external/libhevc/encoder/
Dihevce_multi_thrd_funcs.c496 HEVCE_ENC_JOB_TYPES_T task_type; in ihevce_prepare_job_queue() local
587 HEVCE_ENC_JOB_TYPES_T task_type; in ihevce_prepare_job_queue() local

12