Home
last modified time | relevance | path

Searched refs:job (Results 1 – 25 of 26) sorted by relevance

12

/test/vti/test_serving/gae/webapp/src/tasks/
Dindexing_test.py57 job = model.JobModel()
58 job.priority = schedule.priority
59 job.test_name = schedule.test_name
60 job.period = schedule.period
61 job.build_storage_type = schedule.build_storage_type
62 job.manifest_branch = schedule.manifest_branch
63 job.build_target = schedule.build_target
64 job.pab_account_id = schedule.device_pab_account_id
65 job.shards = schedule.shards
66 job.retry_count = schedule.retry_count
[all …]
/test/vti/test_serving/gae/webapp/src/endpoint/
Djob_queue.py57 job = priority_sorted_jobs[0]
58 job.status = Status.JOB_STATUS_DICT["leased"]
59 job.put()
62 common_attributes = self.GetCommonAttributes(job, model.JobMessage)
64 setattr(job_message, attr, getattr(job, attr))
67 model.DeviceModel.serial.IN(job.serial))
113 job = same_jobs[0]
115 common_attributes = self.GetCommonAttributes(job, model.JobMessage)
117 setattr(job_message, attr, getattr(job, attr))
120 model.DeviceModel.serial.IN(job.serial))
[all …]
Dendpoint_base_test.py55 job = model.JobModel()
57 setattr(job, attr, attr)
58 result = self.eb.GetAttributes(job, assigned_only=True)
100 job = model.JobModel()
102 setattr(job, attr, attr)
103 result = self.eb.GetAttributes(job, assigned_only=False)
Djob_queue_test.py83 job = model.JobModel()
85 setattr(job, key, test_values[key])
86 job.timestamp = datetime.datetime.now()
87 job.put()
/test/vti/test_serving/gae/webapp/src/scheduler/
Djob_heartbeat.py52 for job in jobs:
53 if job.heartbeat_stamp:
54 job_timestamp = job.heartbeat_stamp
56 job_timestamp = job.timestamp
59 lost_jobs.append(job)
63 for job in lost_jobs:
66 job.hostname, job.device, job.test_name))
67 job.status = Status.JOB_STATUS_DICT["infra-err"]
68 lost_jobs_to_put.append(job)
70 job, Status.JOB_STATUS_DICT["infra-err"])
[all …]
Dschedule_worker_test.py256 any([job.test_name == schedule2_h.test_name for job in jobs]))
258 any([job.test_name == schedule2_m.test_name for job in jobs]))
276 any([job.test_name == schedule2_m.test_name for job in jobs]))
293 any([job.test_name == schedule2_m.test_name for job in jobs]))
/test/vti/test_serving/gae/frontend/src/app/menu/job/
Djob.component.ts175 … job => (moment() - moment.tz(job.timestamp, 'YYYY-MM-DDThh:mm:ss', 'UTC')) / 3600000 < 24);
191 …completed: jobs.filter(job => job.status != null && Number(job.status) === JobStatus.Complete).len…
192 running: jobs.filter(job => job.status != null &&
193 (Number(job.status) === JobStatus.Leased || Number(job.status) === JobStatus.Ready)).length,
194 …bootup_err: jobs.filter(job => job.status != null && Number(job.status) === JobStatus.Bootup_err).…
195 …infra_err: jobs.filter(job => job.status != null && Number(job.status) === JobStatus.Infra_err).le…
196 …expired: jobs.filter(job => job.status != null && Number(job.status) === JobStatus.Expired).length,
/test/vti/test_serving/gae/webapp/src/utils/
Demail_util.py113 for job in jobs:
115 model.LabModel.hostname == job.hostname)
129 labs_to_alert[lab.name]["jobs"].append(job)
133 job.hostname))
156 for job in labs_to_alert[lab]["jobs"]:
157 message += "hostname: {}\n\n".format(job.hostname)
158 message += "device: {}\n".format(job.device.split("/")[1])
159 message += "device serial: {}\n".format(", ".join(job.serial))
162 job.manifest_branch, job.build_target, job.build_id)
164 job.gsi_branch, job.gsi_build_target, job.gsi_build_id)
[all …]
Dmodel_util_test.py71 job = jobs[0]
72 job.status = Status.JOB_STATUS_DICT["infra-err"]
73 parent_schedule = job.parent_schedule.get()
81 job.put()
82 model_util.UpdateParentSchedule(job, job.status)
89 for job in jobs:
90 job.timestamp = datetime.datetime.now() - datetime.timedelta(
92 job.put()
147 for job in jobs:
148 job.timestamp = datetime.datetime.now() - datetime.timedelta(
[all …]
Dmodel_util.py22 def UpdateParentSchedule(job, status): argument
37 if job.parent_schedule:
38 schedule = job.parent_schedule.get()
/test/framework/harnesses/host_controller/vti_interface/
Dvti_endpoint_client.py287 for job in jobs:
289 self._job = job
291 return job["test_name"].split("/")[0], job
294 def ExecuteJob(self, job): argument
304 logging.info("Job info : {}".format(json.dumps(job)))
305 if job is not None:
306 self._job = job
308 return job["test_name"].split("/")[0], job
/test/vti/test_serving/gae/webapp/src/testing/
Dunittest_base.py326 for job in jobs:
327 if job.timestamp:
328 job.timestamp -= datetime.timedelta(
330 if job.heartbeat_stamp:
331 job.heartbeat_stamp -= datetime.timedelta(
333 to_put.append(job)
/test/vti/dashboard/src/main/java/com/android/vts/util/
DDatastoreHelper.java30 import com.android.vts.job.VtsAlertJobServlet;
31 import com.android.vts.job.VtsCoverageAlertJobServlet;
32 import com.android.vts.job.VtsProfilingStatsJobServlet;
/test/vti/dashboard/src/main/java/com/android/vts/job/
DBaseJobServlet.java17 package com.android.vts.job;
DVtsSpreadSheetSyncServlet.java17 package com.android.vts.job;
DVtsInactivityJobServlet.java17 package com.android.vts.job;
DVtsPerformanceJobServlet.java17 package com.android.vts.job;
DVtsCoverageAlertJobServlet.java17 package com.android.vts.job;
DVtsSuiteTestJobServlet.java17 package com.android.vts.job;
DVtsProfilingStatsJobServlet.java17 package com.android.vts.job;
/test/vti/dashboard/src/test/java/com/android/vts/api/
DVtsSpreadSheetSyncServletTest.java20 import com.android.vts.job.VtsSpreadSheetSyncServlet;
/test/vti/dashboard/src/test/java/com/android/vts/job/
DVtsAlertJobServletTest.java17 package com.android.vts.job;
DVtsPerformanceJobServletTest.java17 package com.android.vts.job;
DVtsProfilingStatsJobServletTest.java17 package com.android.vts.job;
/test/framework/harnesses/host_controller/
Dconsole.py866 for job in jobs:
867 job.join()

12