| /external/tensorflow/tensorflow/python/training/ |
| D | server_lib.py | 27 def _make_server_def(server_or_cluster_def, job_name, task_index, protocol, argument
35 job_name: (Optional.) Specifies the name of the job of which the server is a
56 if job_name is not None:
57 server_def.job_name = job_name
70 if job_name is None:
72 job_name = cluster_spec.jobs[0]
74 raise ValueError("Must specify an explicit `job_name`.")
76 task_indices = cluster_spec.task_indices(job_name)
86 job_name=job_name,
109 job_name=None, argument
[all …]
|
| /external/curl/ |
| D | appveyor.yml | 46 - job_name: 'CMake, VS2022, Release, x64, OpenSSL 3.4, Shared, Build-tests'
56 - job_name: 'CMake, VS2022, Release, arm64, Schannel, Static, Build-tests'
66 - job_name: 'CMake, VS2010, Release, x86, Schannel, Static, Build-tests'
75 - job_name: 'CMake, VS2010, Debug, x64, Schannel, Static, Build-tests & examples'
85 - job_name: 'CMake, VS2012, Debug, x64, OpenSSL 1.1.1, Build-tests'
95 - job_name: 'CMake, VS2013, Debug, x64, OpenSSL 1.1.1, Build-only'
106 - job_name: 'CMake, VS2015, Debug, x64, OpenSSL 1.1.1, Build-only'
117 - job_name: 'CMake, VS2017, Debug, x64, OpenSSL 1.1.1, Build-only'
128 …- job_name: 'CMake, VS2022, Debug, x64, Schannel, Static, Unicode, Build-tests & examples, clang-c…
138 - job_name: 'CMake, VS2022, Debug, x64, Schannel, Static, Unicode, Build-tests'
[all …]
|
| /external/pytorch/.github/scripts/ |
| D | test_filter_test_configs.py | 367 "job_name": "a CI job",
372 "job_name": "a-ci-job",
377 "job_name": "a-ci-cuda11.8-job",
382 "job_name": "a-ci-rocm-job",
387 "job_name": "",
398 job_name = case.get("job_name", None)
400 scheduled_test_matrix = set_periodic_modes(test_matrix, job_name)
403 m for m, c in SUPPORTED_PERIODICAL_MODES.items() if c(job_name)
417 "job_name": "invalid job name",
424 "job_name": "mock-platform-1 / build",
[all …]
|
| D | filter_test_configs.py | 25 def is_cuda_or_rocm_job(job_name: Optional[str]) -> bool:
26 if not job_name:
29 return "cuda" in job_name or "rocm" in job_name
37 "rerun_disabled_tests": lambda job_name: True,
209 test_matrix: Dict[str, List[Any]], job_name: Optional[str]
220 if not cond(job_name):
231 workflow: str, job_name: str, test_matrix: Dict[str, List[Any]]
239 job_name=job_name,
247 workflow: str, job_name: str, test_matrix: Dict[str, List[Any]]
255 job_name=job_name,
[all …]
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/service/ |
| D | cross_trainer_cache_test.py | 42 job_name="job",
51 job_name="job",
69 job_name="job",
81 job_name="job",
91 dataset1 = self.make_distributed_dataset(dataset, cluster, job_name="job")
96 dataset2 = self.make_distributed_dataset(dataset, cluster, job_name="job")
125 job_name="job",
147 job_name="job",
155 job_name="job",
181 job_name="job",
[all …]
|
| D | data_service_ops_test.py | 306 with self.assertRaisesRegex(ValueError, "`job_name` must not be empty"):
312 job_name=""))
323 with self.assertRaisesRegex(ValueError, "`job_name` must not be empty"):
328 job_name="")
335 with self.assertRaisesRegex(ValueError, "`job_name` must be a string"):
341 job_name=constant_op.constant("foo")))
352 with self.assertRaisesRegex(ValueError, "`job_name` must be a string"):
358 job_name=constant_op.constant("foo"))
373 job_name="job_name",
378 job_name="job_name",
[all …]
|
| D | local_workers_test.py | 142 num_elements, cluster, job_name="shared_job")
207 ds, cluster, job_name="test_job", target_workers=target_workers)
253 job_name="test_job",
298 cluster, job_name="shared_job_name")
309 num_remote_workers=[0, 3], job_name=[None, "shared_job_name"])))
310 def testRepeatDistributedDataset(self, num_remote_workers, job_name): argument
316 10, cluster, job_name=job_name, target_workers="LOCAL")
331 cluster, job_name="shared_job_name")
339 cluster, job_name="shared_job_name")
356 cluster, job_name="shared_job_name")
[all …]
|
| /external/perfetto/src/trace_processor/perfetto_sql/stdlib/android/ |
| D | job_scheduler_states.sql | 29 extract_arg(arg_set_id, 'scheduled_job_state_changed.job_name') AS job_name, field
71 …lead(state, 1) OVER (PARTITION BY uid, job_name, job_id ORDER BY uid, job_name, job_id, ts) AS lea…
72 …lead(ts, 1, trace_end()) OVER (PARTITION BY uid, job_name, job_id ORDER BY uid, job_name, job_id, …
74 …lead(ts, 1) OVER (PARTITION BY uid, job_name, job_id ORDER BY uid, job_name, job_id, ts) IS NULL A…
75 … 'INTERNAL_STOP_REASON_UNKNOWN') OVER (PARTITION BY uid, job_name, job_id ORDER BY uid, job_name, …
76 …1, 'PUBLIC_STOP_REASON_UNKNOWN') OVER (PARTITION BY uid, job_name, job_id ORDER BY uid, job_name, …
87 WHEN substr(job_name, 1, 1) = '@'
89 WHEN substr(str_split(job_name, '/', 1), 1, 3) = 'com'
90 THEN str_split(job_name, '/', 1)
91 ELSE str_split(str_split(job_name, '/', 0), '@', 2)
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_tensorflow_server.cc | 41 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()
60 // job_str is of form <job_name>|<host_ports>. 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()
89 << " --cluster_spec=SPEC --job_name=NAME --task_id=ID" << std::endl; in Usage()
[all …]
|
| /external/tensorflow/tensorflow/python/eager/ |
| D | remote_execution_test.py | 38 JOB_NAME = "remote_device" variable
42 def get_server_def(job_name, local_server_port, remote_server_addresses, argument
47 job_def.name = job_name
55 job_name=job_name,
77 JOB_NAME,
97 with ops.device("/job:%s/replica:0/task:1/device:CPU:0" % JOB_NAME):
107 with ops.device("job:%s/replica:0/task:1/device:CPU:0" % JOB_NAME):
117 with ops.device("job:%s/replica:0/task:1/device:CPU:0" % JOB_NAME):
119 with ops.device("job:%s/replica:0/task:2/device:CPU:0" % JOB_NAME):
128 with ops.device("job:%s/replica:0/task:1/device:CPU:0" % JOB_NAME):
[all …]
|
| D | remote.py | 38 def connect_to_remote_host(remote_host=None, job_name="worker"): argument
45 Using the default job_name of worker, you can schedule ops to run remotely as
61 job_name: The job name under which the new server will be accessible.
71 {job_name: [_strip_prefix(host, _GRPC_PREFIX) for host in remote_hosts]})
78 job_name="localhost", argument
119 job_name: The name of the local job.
163 if current_server_def and job_name not in cluster_spec.jobs:
165 if job.name == job_name:
168 current_server_def.job_name != job_name or
173 if job_name not in cluster_spec.jobs:
[all …]
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | grpc_tensorflow_server.py | 17 Takes input arguments cluster_spec, job_name and task_id, and start a blocking
21 grpc_tensorflow_server.py --cluster_spec=SPEC --job_name=NAME --task_id=ID
66 job_name = job_string.split("|")[0]
68 if not job_name:
69 raise ValueError("Empty job_name in cluster_spec")
71 job_def.name = job_name
74 logging.info("Added job named \"%s\"", job_name)
85 job_tasks[i], job_name)
96 if not FLAGS.job_name:
97 raise ValueError("Empty job_name")
[all …]
|
| /external/pytorch/tools/stats/ |
| D | test_dashboard.py | 43 def get_build_name(job_name: str) -> str:
45 return re.match(REGEX_JOB_INFO, job_name).group(1) # type: ignore[union-attr]
47 print(f"Failed to match job name: {job_name}")
52 def get_test_config(job_name: str) -> str:
54 return re.match(REGEX_JOB_INFO, job_name).group(2) # type: ignore[union-attr]
56 print(f"Failed to match job name: {job_name}")
80 job_name = get_job_name(job_id)
81 build_name = get_build_name(job_name)
82 test_config = get_test_config(job_name)
99 job_name = get_job_name(test_case["job_id"])
[all …]
|
| /external/tensorflow/tensorflow/python/data/experimental/ops/ |
| D | data_service_ops.py | 135 job_name="job",
181 def _validate_job_name(job_name): argument
182 if job_name is None:
184 if not isinstance(job_name, str):
185 raise ValueError("`job_name` must be a string, but `job_name` was of type "
186 f"{type(job_name)}. job_name={job_name}")
187 if not job_name:
188 raise ValueError("`job_name` must not be empty")
246 job_name=None, argument
270 job_name: (Optional.) The name of the job. If provided, it must be a
[all …]
|
| /external/autotest/tko/ |
| D | site_parse_unittest.py | 65 job_name='x86-alex-r16-R16-1166.0.0-a1-b1118_bvt', argument
69 board, rev, version = self._stack_trace._parse_job_name(job_name)
79 return job_name, symbols_dir, chroot_symbols_dir
83 job_name = 'x86-alex-r16-R16-1166.0.0-a1-b1118_regression'
85 f.write('label=%s' % job_name)
87 self.assertEqual(self._stack_trace._get_job_name(), job_name)
91 job_name = 'x86-alex-r16-R16-1166.0.0-a1-b1118_regression'
92 board, rev, version = self._stack_trace._parse_job_name(job_name)
99 job_name = 'x86-mario-r15-0.15.1011.74-a1-b61_bvt'
100 board, rev, version = self._stack_trace._parse_job_name(job_name)
[all …]
|
| /external/grpc-grpc/tools/distrib/ |
| D | update_flakes_query.py | 26 job_name,
61 job_name,
69 job_name,
75 job_name,
81 job_name,
99 job_name,
110 job_name,
130 job_name
140 job_name,
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/distrib/ |
| D | update_flakes_query.py | 26 job_name,
61 job_name,
69 job_name,
75 job_name,
81 job_name,
99 job_name,
110 job_name,
130 job_name
140 job_name,
|
| /external/google-cloud-java/java-scheduler/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1/it/ |
| D | ITSystemTest.java | 56 private static final String JOB_NAME = JobName.of(PROJECT, LOCATION, JOB).toString().trim(); field in ITSystemTest
74 .setName(JOB_NAME) in setUp()
84 client.deleteJob(JOB_NAME); in tearDown()
91 assertEquals(JOB_NAME, job.getName()); in assertJobDetails()
100 Job job = client.getJob(JOB_NAME); in getJobTest()
108 if (JOB_NAME.equals(job.getName())) { in listJobsTest()
117 Job pauseJob = client.pauseJob(JOB_NAME); in pauseAndResumeJobTest()
124 Job resumeJob = client.resumeJob(JOB_NAME); in pauseAndResumeJobTest()
134 .setName(JOB_NAME) in updateJobTest()
141 assertEquals(JOB_NAME, job.getName()); in updateJobTest()
[all …]
|
| /external/google-cloud-java/java-scheduler/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/it/ |
| D | ITSystemTest.java | 55 private static final String JOB_NAME = JobName.of(PROJECT, LOCATION, JOB).toString().trim(); field in ITSystemTest
73 .setName(JOB_NAME) in setUp()
83 client.deleteJob(JOB_NAME); in tearDown()
90 assertEquals(JOB_NAME, job.getName()); in assertJobDetails()
99 Job job = client.getJob(JOB_NAME); in getJobTest()
107 if (JOB_NAME.equals(job.getName())) { in listJobsTest()
116 Job pauseJob = client.pauseJob(JOB_NAME); in pauseAndResumeJobTest()
123 Job resumeJob = client.resumeJob(JOB_NAME); in pauseAndResumeJobTest()
133 .setName(JOB_NAME) in updateJobTest()
140 assertEquals(JOB_NAME, job.getName()); in updateJobTest()
[all …]
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | cluster.proto | 38 // 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/grpc-grpc/tools/internal_ci/linux/ |
| D | grpc_xds_resource_cleanup.sh | 89 # TODO(sergiitk): turn job_name into action test methods of the cleanup.
92 # ${TEST_XML_OUTPUT_DIR}/${job_name}/sponge_log.log
95 local job_name="${1:?Usage: cleanup::run_clean job_name}"
96 local out_dir="${TEST_XML_OUTPUT_DIR}/${job_name}"
98 # TODO(sergiitk): make it a test, where job_name is a separate method.
135 for job_name in "${cleanup_jobs[@]}"; do
136 echo "-------------------- Starting job ${job_name} --------------------"
138 "cleanup::job::${job_name}" "${job_name}" || (( ++failed_jobs ))
140 echo "-------------------- Finished job ${job_name} --------------------"
|
| /external/tensorflow/tensorflow/core/data/service/client/ |
| D | validate_utils_test.cc | 110 params.job_name = "job_name"; in TEST()
128 "Cross-trainer caching requires named jobs. Got empty `job_name`.")); in TEST()
133 params.job_name = "job_name"; in TEST()
146 params.job_name = "job_name"; in TEST()
162 params.job_name = "job_name"; in TEST()
|
| /external/autotest/utils/frozen_chromite/third_party/infra_libs/ts_mon/common/ |
| D | targets.py | 94 def __init__(self, service_name, job_name, region, hostname, task_num=0): argument
99 job_name (str): specific name of this task.
106 self.job_name = job_name
110 self._fields = ('service_name', 'job_name', 'region',
121 collection.task.job_name = self.job_name
|
| /external/pytorch/tools/alerts/ |
| D | create_alerts.py | 70 job_name: str = "" variable in JobStatus
78 def __init__(self, job_name: str, job_statuses: list[Any]) -> None:
79 self.job_name = job_name
167 disabled_alert not in self.job_name
173 return f"jobName: {self.job_name}"
226 if job_status.job_name not in filtered_jobs_names:
239 job_name for job_name in job_names if re.match(job_name_regex, job_name)
268 "AlertObject": job.job_name,
|
| /external/tensorflow/tensorflow/core/tpu/ |
| D | tpu_global_init.cc | 82 const std::string GetTPUSystemDevice(absl::string_view job_name) { in GetTPUSystemDevice() argument
83 if (job_name.empty()) { in GetTPUSystemDevice()
86 return absl::StrCat("/job:", job_name, "/device:TPU_SYSTEM:0"); in GetTPUSystemDevice()
90 Status ConstructDistributedInitializationGraph(absl::string_view job_name, in ConstructDistributedInitializationGraph() argument
101 .WithDevice(GetTPUSystemDevice(job_name)), in ConstructDistributedInitializationGraph()
137 Status InitializeTPUSystemGlobally(absl::string_view job_name, in InitializeTPUSystemGlobally() argument
155 job_name.empty() ? kTaskSpec in InitializeTPUSystemGlobally()
156 : absl::StrCat("/job:", job_name, "/replica:0/task:0"); in InitializeTPUSystemGlobally()
163 job_name, device_set, graph_to_run.get())); in InitializeTPUSystemGlobally()
208 return InitializeTPUSystemGlobally(/*job_name=*/absl::string_view(), in InitializeTPUSystemGlobally()
|