Home
last modified time | relevance | path

Searched refs:job_name (Results 1 – 25 of 76) sorted by relevance

1234

/external/tensorflow/tensorflow/python/training/
Dserver_lib.py30 def _make_server_def(server_or_cluster_def, job_name, task_index, protocol, argument
61 if job_name is not None:
62 server_def.job_name = job_name
75 if job_name is None:
77 job_name = cluster_spec.jobs[0]
81 task_indices = cluster_spec.task_indices(job_name)
91 job_name=job_name, task_index=task_index, protocol=protocol)
112 job_name=None, argument
147 job_name, task_index, protocol, config)
286 for job_name, tasks in cluster.items():
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_tensorflow_server.cc41 Status FillServerDef(const string& cluster_spec, const string& job_name, in FillServerDef() argument
44 options->set_job_name(job_name); in FillServerDef()
56 const string& job_name = job_pieces[0]; in FillServerDef() local
57 job_def->set_name(job_name); in FillServerDef()
66 if (job_name == options->job_name()) { in FillServerDef()
69 LOG(INFO) << "Peer " << job_name << " " << num_tasks << " {" in FillServerDef()
73 return errors::InvalidArgument("Job name \"", options->job_name(), in FillServerDef()
78 " is invalid (job \"", options->job_name(), in FillServerDef()
100 tensorflow::string job_name; in main() local
104 tensorflow::Flag("job_name", &job_name, "job name"), in main()
[all …]
Dgrpc_testlib_server.cc38 Status FillServerDef(const string& job_spec, const string& job_name, in FillServerDef() argument
42 options->set_job_name(job_name); in FillServerDef()
60 if (job_def->name() == options->job_name()) { in FillServerDef()
81 tensorflow::string job_name; in main() local
87 tensorflow::Flag("tf_job", &job_name, "job name"), in main()
100 tensorflow::Status s = tensorflow::FillServerDef(job_spec, job_name, num_cpus, in main()
Dgrpc_server_lib.cc127 if (job.name() == server_def_.job_name()) { in Init()
132 server_def_.job_name(), "\""); in Init()
145 return errors::Internal("Job \"", server_def_.job_name(), in Init()
155 strings::StrCat("/job:", server_def_.job_name(), "/replica:0", in Init()
294 if (job.name() == *options.job_name && task.first == options.task_index) { in ParseChannelSpec()
307 if (options.job_name == nullptr || options.job_name->empty()) { in WorkerCacheFactory()
322 string name_prefix = strings::StrCat("/job:", *options.job_name, "/replica:0", in WorkerCacheFactory()
Dgrpc_channel.cc194 void ListWorkersInJob(const string& job_name, in ListWorkersInJob() argument
197 cache->ListWorkersInJob(job_name, workers); in ListWorkersInJob()
261 void ListWorkersInJob(const string& job_name, in ListWorkersInJob() argument
263 if (job_name == job_id_) { in ListWorkersInJob()
/external/autotest/tko/
Dsite_parse_unittest.py61 job_name='x86-alex-r16-R16-1166.0.0-a1-b1118_bvt', argument
65 board, rev, version = self._stack_trace._parse_job_name(job_name)
75 return job_name, symbols_dir, chroot_symbols_dir
79 job_name = 'x86-alex-r16-R16-1166.0.0-a1-b1118_regression'
81 f.write('label=%s' % job_name)
83 self.assertEqual(self._stack_trace._get_job_name(), job_name)
87 job_name = 'x86-alex-r16-R16-1166.0.0-a1-b1118_regression'
88 board, rev, version = self._stack_trace._parse_job_name(job_name)
95 job_name = 'x86-mario-r15-0.15.1011.74-a1-b61_bvt'
96 board, rev, version = self._stack_trace._parse_job_name(job_name)
[all …]
Dsite_parse.py115 def _parse_job_name(self, job_name): argument
128 version = job_name.rsplit('-', 3)[1].split('_')[-1]
129 arch, board, rev = job_name.split('-', 3)[:3]
/external/grpc-grpc/tools/failures/sql/
Dnew_failures_24h.sql6 job_name,
12 job_name,
20 AND NOT REGEXP_CONTAINS(job_name,
28 job_name,
35 job_name,
43 AND NOT REGEXP_CONTAINS(job_name,
50 reporting.job_name,
/external/tensorflow/tensorflow/python/debug/lib/
Dgrpc_tensorflow_server.py69 job_name = job_string.split("|")[0]
71 if not job_name:
74 job_def.name = job_name
77 logging.info("Added job named \"%s\"", job_name)
88 job_tasks[i], job_name)
99 if not FLAGS.job_name:
101 server_def.job_name = FLAGS.job_name
/external/tensorflow/tensorflow/core/protobuf/
Dcluster.proto37 // cluster { $CLUSTER } job_name: 'local' task_index: 0
46 // cluster { $CLUSTER } job_name: 'local' task_index: 0
47 // cluster { $CLUSTER } job_name: 'local' task_index: 1
60 // cluster { $CLUSTER } job_name: 'worker' task_index: 0
61 // cluster { $CLUSTER } job_name: 'worker' task_index: 1
62 // cluster { $CLUSTER } job_name: 'worker' task_index: 2
63 // cluster { $CLUSTER } job_name: 'ps' task_index: 0
64 // cluster { $CLUSTER } job_name: 'ps' task_index: 1
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dcluster_resolver.py361 for job_name, tasks in cluster_dict.items():
362 if job_name in merged_cluster:
365 merged_cluster[job_name] = {}
369 merged_cluster[job_name] = []
371 merged_cluster[job_name] = {}
378 for job_name, tasks in cluster_dict.items():
379 if isinstance(merged_cluster[job_name], list):
381 merged_cluster[job_name].extend(tasks)
392 merged_keys = set(merged_cluster[job_name].keys())
399 merged_cluster[job_name].update(task_dict)
/external/tensorflow/tensorflow/python/eager/
Dremote.py30 def connect_to_remote_host(remote_host=None, job_name="worker"): argument
68 job_def.name = job_name
74 job_name=job_name,
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster_env.h39 const string* job_name = nullptr; member
49 if (server_def.has_cluster() && !server_def.job_name().empty()) { in WorkerCacheFactoryOptions()
51 job_name = &server_def.job_name(); in WorkerCacheFactoryOptions()
Dworker_cache_wrapper.h35 virtual void ListWorkersInJob(const string& job_name, in ListWorkersInJob() argument
37 return wrapped_->ListWorkersInJob(job_name, workers); in ListWorkersInJob()
/external/tensorflow/tensorflow/tools/api/golden/v1/
Dtensorflow.train.-cluster-spec.pbtxt23 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
27 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
31 …argspec: "args=[\'self\', \'job_name\', \'task_index\'], varargs=None, keywords=None, defaults=Non…
35 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
/external/tensorflow/tensorflow/tools/api/golden/v2/
Dtensorflow.train.-cluster-spec.pbtxt23 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
27 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
31 …argspec: "args=[\'self\', \'job_name\', \'task_index\'], varargs=None, keywords=None, defaults=Non…
35 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
/external/grpc-grpc/tools/failures/
Ddetect_new_failures.py74 def build_kokoro_url(job_name, build_id): argument
75 job_path = '{}/{}'.format('/job/'.join(job_name.split('/')), build_id)
81 poll_strategy, job_name, build_id, timestamp = results_row
85 url = build_kokoro_url(job_name, build_id)
118 poll_strategy, job_name, build_id, timestamp = results_row
119 full_kokoro_url = build_kokoro_url(job_name, build_id)
153 job_name=row['f'][2]['v'],
/external/libcups/cups/
Dnotify.c39 *job_name, /* job-name */ in cupsNotifySubject() local
59 job_name = ippFindAttribute(event, "job-name", IPP_TAG_NAME); in cupsNotifySubject()
108 job_name ? job_name->values[0].string.text : in cupsNotifySubject()
/external/autotest/site_utils/admin/scripts/
Dcheck_db_queries.sql88 …ct count(*) as values_per_board, left(job_name,instr(job_name,'-0')-1) as board from tko_perf_view…
/external/grpc-grpc/tools/run_tests/python_utils/
Dupload_test_results.py77 job_name = os.getenv('KOKORO_JOB_NAME')
83 if job_name:
84 test_results['job_name'] = job_name
/external/tensorflow/tensorflow/core/grappler/costs/
Dvirtual_placer_test.cc115 for (const string& job_name : {"localhost", "worker", "worker_train"}) { in TEST()
119 devices[strings::StrCat("/job:", job_name, "/replica:0/task:0/cpu:0")] = in TEST()
123 devices[strings::StrCat("/job:", job_name, in TEST()
131 EXPECT_EQ(strings::StrCat("/job:", job_name, "/replica:0/task:0/cpu:0"), in TEST()
135 strings::StrCat("/job:", job_name, "/replica:0/task:0/device:GPU:0"), in TEST()
/external/autotest/client/common_lib/cros/
Darc.py310 def get_job_pid(job_name): argument
312 status = utils.system_output('status %s' % job_name)
313 match = re.match(r'^%s start/running, process (\d+)$' % job_name,
338 def _get_mount_passthrough_pid_internal(job_name): argument
340 job_pid = get_job_pid(job_name)
353 for job_name in JOB_NAMES:
355 pid = _get_mount_passthrough_pid_internal(job_name)
358 logging.warning('Failed to find PID for %s : %s', job_name, e)
/external/tensorflow/tensorflow/contrib/eager/python/
Dremote_test.py60 def get_server_def(job_name, local_server_port, remote_server_addresses, argument
65 job_def.name = job_name
73 job_name=job_name,
/external/grpc-grpc/tools/run_tests/performance/
Dbq_upload_result.py137 job_name = os.getenv('KOKORO_JOB_NAME')
150 if job_name:
151 metadata['jobName'] = job_name
/external/autotest/server/cros/dynamic_suite/
Djob_status_unittest.py105 job_name = 'broken_infra_job'
112 status.entry['job'] = {'name': job_name}
119 expected_name = '%s_%s' % (job_name, job.statuses[i].test_name)

1234