Home
last modified time | relevance | path

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

12345

/external/tensorflow/tensorflow/python/training/
Dserver_lib.py31 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,
113 job_name=None, argument
146 self._server_def = _make_server_def(server_or_cluster_def, job_name,
292 for job_name, tasks in cluster.items():
[all …]
/external/tensorflow/tensorflow/python/data/experimental/ops/
Ddata_service_ops.py63 job_name=None, argument
108 if num_consumers is not None and job_name is None:
111 if job_name is None:
112 job_name = ""
127 job_name, dtype=dtypes.string, name="job_name")
154 job_name=self._job_name,
167 job_name=self._job_name,
188 data_transfer_protocol, job_name, consumer_index, num_consumers, argument
197 job_name=job_name,
242 job_name=None, argument
[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.cc134 if (job.name() == server_def.job_name()) { in GetHostAndPort()
139 server_def.job_name(), "\""); in GetHostAndPort()
162 return errors::Internal("Job \"", server_def.job_name(), in GetHostAndPort()
187 strings::StrCat("/job:", server_def_.job_name(), "/replica:0", in Init()
348 if (job.name() == *options.job_name && task.first == options.task_index) { in ParseChannelSpec()
361 if (options.job_name == nullptr || options.job_name->empty()) { in WorkerCacheFactory()
376 string name_prefix = strings::StrCat("/job:", *options.job_name, "/replica:0", in WorkerCacheFactory()
/external/tensorflow/tensorflow/python/eager/
Dremote.py42 def connect_to_remote_host(remote_host=None, job_name="worker"): argument
75 {job_name: [_strip_prefix(host, _GRPC_PREFIX) for host in remote_hosts]})
82 job_name="localhost", argument
164 if job_name not in cluster_spec.jobs:
167 job_def.name = job_name
174 job_name=job_name,
191 for job_name in cluster_spec.jobs:
192 for task_id in cluster_spec.task_indices(job_name):
193 task_address = cluster_spec.task_address(job_name, task_id)
195 master_job_name = job_name
/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/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 …]
/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.proto38 // cluster { $CLUSTER } job_name: 'local' task_index: 0
47 // cluster { $CLUSTER } job_name: 'local' task_index: 0
48 // cluster { $CLUSTER } job_name: 'local' task_index: 1
61 // cluster { $CLUSTER } job_name: 'worker' task_index: 0
62 // cluster { $CLUSTER } job_name: 'worker' task_index: 1
63 // cluster { $CLUSTER } job_name: 'worker' task_index: 2
64 // cluster { $CLUSTER } job_name: 'ps' task_index: 0
65 // cluster { $CLUSTER } job_name: 'ps' task_index: 1
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dcluster_resolver.py531 for job_name, tasks in cluster_dict.items():
532 if job_name in merged_cluster:
535 merged_cluster[job_name] = {}
539 merged_cluster[job_name] = []
541 merged_cluster[job_name] = {}
548 for job_name, tasks in cluster_dict.items():
549 if isinstance(merged_cluster[job_name], list):
551 merged_cluster[job_name].extend(tasks)
562 merged_keys = set(merged_cluster[job_name].keys())
569 merged_cluster[job_name].update(task_dict)
/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()
/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/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/python/data/experimental/kernel_tests/
Ddata_service_test_base.py211 job_name=None, argument
220 job_name=job_name,
230 job_name=None, argument
237 job_name=job_name,
Ddata_service_ops_test.py222 ds1 = self.make_distributed_dataset(make_ds(), cluster, job_name="job_name")
223 ds2 = self.make_distributed_dataset(make_ds(), cluster, job_name="job_name")
241 num_elements, cluster, job_name="job_name1")
243 num_elements, cluster, job_name="job_name2")
252 num_elements, cluster, job_name="job_name")
254 num_elements, cluster, job_name="job_name")
268 num_elements, cluster, job_name="job_name")
271 num_elements, cluster, job_name="job_name")
302 job_name="test",
365 job_name="test",
[all …]
/external/libcups/tools/
Dippeveps.c239 const char *job_name = getenv("IPP_JOB_NAME"); in dsc_header() local
247 ppdEmitJCL(ppd, stdout, job_id ? atoi(job_id) : 0, cupsUser(), job_name ? job_name : "Unknown"); in dsc_header()
253 if (job_name) in dsc_header()
256 while (*job_name) in dsc_header()
258 if (*job_name >= 0x20 && *job_name < 0x7f) in dsc_header()
259 putchar(*job_name); in dsc_header()
263 job_name ++; in dsc_header()
788 *job_name; /* job-name value */ in pdf_to_ps() local
812 if ((job_name = getenv("IPP_JOB_NAME")) == NULL) in pdf_to_ps()
813 job_name = "untitled"; in pdf_to_ps()
[all …]
/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/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/libcups/cups/
Dnotify.c34 *job_name, /* job-name */ in cupsNotifySubject() local
54 job_name = ippFindAttribute(event, "job-name", IPP_TAG_NAME); in cupsNotifySubject()
103 job_name ? job_name->values[0].string.text : in cupsNotifySubject()
/external/protobuf/benchmarks/util/
Dresult_uploader.py27 job_name = os.getenv('JOB_NAME')
39 if job_name:
40 metadata['jobName'] = job_name
/external/tensorflow/tensorflow/core/kernels/data/
Ddataset_utils_test.cc305 string job_name = "job"; in TEST_P() local
313 job_name, live_experiments, optimizations_enabled, optimizations_disabled, in TEST_P()
355 string job_name = "job"; in TEST_P() local
362 job_name, live_experiments, optimizations_enabled, optimizations_disabled, in TEST_P()
421 string job_name = "job"; in TEST_P() local
430 job_name, live_experiments, optimizations_enabled, optimizations_disabled, in TEST_P()
461 const string job_name = std::get<0>(GetParam()); in TEST_P() local
476 job_name, live_experiments, optimizations_enabled, optimizations_disabled, in TEST_P()
480 if (job_name.empty()) { in TEST_P()
/external/rust/crates/grpcio-sys/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/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()

12345