Home
last modified time | relevance | path

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

123

/external/tensorflow/tensorflow/python/training/
Dserver_lib.py29 def _make_server_def(server_or_cluster_def, job_name, task_index, protocol, argument
60 if job_name is not None:
61 server_def.job_name = job_name
74 if job_name is None:
76 job_name = cluster_spec.jobs[0]
80 task_indices = cluster_spec.task_indices(job_name)
90 job_name=job_name, task_index=task_index, protocol=protocol)
110 job_name=None, argument
144 job_name, task_index, protocol, config)
273 for job_name, tasks in cluster.items():
[all …]
Dserver_lib_test.py196 job_name="localhost",
208 }, job_name="local", task_index=0)
341 cluster=cluster_def, job_name="local", task_index=0, protocol="grpc")
359 cluster=cluster_def, job_name="local", task_index=1, protocol="grpc")
379 cluster=cluster_def, job_name="worker", task_index=2, protocol="grpc")
405 cluster=cluster_def, job_name="worker", task_index=2, protocol="grpc")
/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.cc121 strings::StrCat("/job:", server_def_.job_name(), "/replica:0", in Init()
140 if (job.name() == server_def_.job_name()) { in Init()
145 server_def_.job_name(), "\""); in Init()
160 return errors::Internal("Job \"", server_def_.job_name(), in Init()
264 if (job.name() == *options.job_name && task.first == options.task_index) { in ParseChannelSpec()
277 if (options.job_name == nullptr || options.job_name->empty()) { in WorkerCacheFactory()
292 string name_prefix = strings::StrCat("/job:", *options.job_name, "/replica:0", in WorkerCacheFactory()
/external/tensorflow/tensorflow/contrib/cluster_resolver/python/training/
Dcluster_resolver.py131 for job_name, tasks in cluster_dict.items():
132 if job_name in merged_cluster:
135 merged_cluster[job_name] = {}
139 merged_cluster[job_name] = []
141 merged_cluster[job_name] = {}
148 for job_name, tasks in cluster_dict.items():
149 if isinstance(merged_cluster[job_name], list):
151 merged_cluster[job_name].extend(tasks)
162 merged_keys = set(merged_cluster[job_name].keys())
169 merged_cluster[job_name].update(task_dict)
Dgce_cluster_resolver_test.py143 job_name='custom',
199 job_name='worker',
208 job_name='worker',
217 job_name='ps',
Dgce_cluster_resolver.py48 job_name='worker', argument
75 self._job_name = job_name
Dtpu_cluster_resolver.py55 job_name='tpu_worker', argument
92 self._job_name = job_name
/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/tensorflow/tensorflow/tools/dist_test/server/
Dgrpc_tensorflow_server.py69 job_name = job_string.split("|")[0]
71 if not job_name:
74 job_def.name = job_name
77 print("Added job named \"%s\"" % job_name)
87 print(" Added task \"%s\" to job \"%s\"" % (job_tasks[i], job_name))
98 if not FLAGS.job_name:
100 server_def.job_name = FLAGS.job_name
/external/tensorflow/tensorflow/core/protobuf/
Dcluster.proto36 // cluster { $CLUSTER } job_name: 'local' task_index: 0
45 // cluster { $CLUSTER } job_name: 'local' task_index: 0
46 // cluster { $CLUSTER } job_name: 'local' task_index: 1
59 // cluster { $CLUSTER } job_name: 'worker' task_index: 0
60 // cluster { $CLUSTER } job_name: 'worker' task_index: 1
61 // cluster { $CLUSTER } job_name: 'worker' task_index: 2
62 // cluster { $CLUSTER } job_name: 'ps' task_index: 0
63 // cluster { $CLUSTER } job_name: 'ps' task_index: 1
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster_env.h38 const string* job_name = nullptr; member
48 if (server_def.has_cluster() && !server_def.job_name().empty()) { in WorkerCacheFactoryOptions()
50 job_name = &server_def.job_name(); in WorkerCacheFactoryOptions()
/external/tensorflow/tensorflow/tools/api/golden/
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"
Dtensorflow.train.-server.pbtxt15 …argspec: "args=[\'self\', \'server_or_cluster_def\', \'job_name\', \'task_index\', \'protocol\', \…
/external/tensorflow/tensorflow/tools/dist_test/python/
Dmnist_replica.py94 if FLAGS.job_name is None or FLAGS.job_name == "":
99 print("job name = %s" % FLAGS.job_name)
114 cluster, job_name=FLAGS.job_name, task_index=FLAGS.task_index)
115 if FLAGS.job_name == "ps":
/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/tensorflow/tensorflow/tools/dist_test/scripts/
Ddist_mnist_test.sh132 --job_name="worker" \
157 --job_name="ps" \
187 --job_name="worker" \
/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/tensorflow/tensorflow/docs_src/deploy/
Ddistributed.md102 server = tf.train.Server(cluster, job_name="local", task_index=0)
107 server = tf.train.Server(cluster, job_name="local", task_index=1)
209 job_name=FLAGS.job_name,
212 if FLAGS.job_name == "ps":
214 elif FLAGS.job_name == "worker":
263 "--job_name",
287 --job_name=ps --task_index=0
292 --job_name=ps --task_index=1
297 --job_name=worker --task_index=0
302 --job_name=worker --task_index=1
/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)
/external/tensorflow/tensorflow/contrib/opt/python/training/
Dvariable_clipping_optimizer_test.py54 worker = server_lib.Server(cs, job_name="worker", start=True)
55 ps = server_lib.Server(cs, job_name="ps", start=True)
/external/autotest/frontend/tko/
Drpc_interface.py264 for job_name in job_names:
265 cursor.execute(query, job_name)
267 summary = summaries.setdefault(job_name, {})

123