Home
last modified time | relevance | path

Searched refs:TASK_ID (Results 1 – 9 of 9) sorted by relevance

/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/training/
DEligibilityDeciderTest.java80 private static final String TASK_ID = "task_1"; field in EligibilityDeciderTest
138 TASK_ID, in testMinSepPolicy_noRecord_eligible()
157 .setTaskId(TASK_ID) in testMinSepPolicy_eligible()
166 TASK_ID, in testMinSepPolicy_eligible()
187 .setTaskId(TASK_ID) in testMinSepPolicy_joinSameRound_notEligible()
209 TASK_ID, in testMinSepPolicy_joinSameRound_notEligible()
228 .setTaskId(TASK_ID) in testMinSepPolicy_joinNextRound_eligible()
251 TASK_ID, in testMinSepPolicy_joinNextRound_eligible()
272 .setTaskId(TASK_ID) in testMinSepPolicy_notEligible()
281 TASK_ID, in testMinSepPolicy_notEligible()
[all …]
DFederatedComputeWorkerTest.java159 private static final String TASK_ID = "task-id"; field in FederatedComputeWorkerTest
200 .setTaskId(TASK_ID)
306 .setTaskId(TASK_ID)
391 .callHandleResult(eq(TASK_ID), any(), any()); in doBeforeEachTest()
795 .callHandleResult(eq(TASK_ID), any(), any()); in testPublishToResultHandlingServiceFails_returnsSuccess()
826 .callHandleResult(eq(TASK_ID), any(), any()); in testPublishToResultHandlingServiceThrowsException_returnsSuccess()
841 verify(mSpyResultCallbackHelper).callHandleResult(eq(TASK_ID), any(), any()); in testPublishToResultHandlingServiceThrowsException_returnsSuccess()
916 .setTaskId(TASK_ID) in testRunFLComputation_emptyTfliteGraph_returns()
984 .setTaskId(TASK_ID) in testRunFLComputation_withDataAvailability_returnsSuccess()
1027 .setTaskId(TASK_ID) in testRunFLComputationNotEligible_returnsFail()
[all …]
/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/data/
DFederatedTrainingTaskDaoTest.java56 private static final String TASK_ID = "task_id"; field in FederatedTrainingTaskDaoTest
72 .setTaskId(TASK_ID)
277 mTrainingTaskDao.getLatestTaskHistory(JOB_ID, POPULATION_NAME, TASK_ID); in insertTaskHistory_success()
291 .setTaskId(TASK_ID) in updateTaskHistory_success()
298 mTrainingTaskDao.getLatestTaskHistory(JOB_ID, POPULATION_NAME, TASK_ID); in updateTaskHistory_success()
310 .setTaskId(TASK_ID) in deleteExpiredTaskHistory_success()
319 .setTaskId(TASK_ID) in deleteExpiredTaskHistory_success()
327 assertThat(mTrainingTaskDao.getTaskHistoryList(JOB_ID, POPULATION_NAME, TASK_ID)) in deleteExpiredTaskHistory_success()
334 assertThat(mTrainingTaskDao.getTaskHistoryList(JOB_ID, POPULATION_NAME, TASK_ID)) in deleteExpiredTaskHistory_success()
/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/examplestore/
DFederatedExampleIteratorTest.java91 private static final long TASK_ID = 1234L; field in FederatedExampleIteratorTest
123 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testNormalHasGetNextResultSuccess()
145 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testGetNextResultSuccess()
170 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testNextResultSuccess()
189 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testCloseWithoutUse()
201 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testCloseAfterHashNext()
216 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testCloseAfterNext()
233 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testExampleStoreIteratorReturnsErrorWhenCallNext()
263 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testExampleStoreIteratorReturnsErrorWhenCallHasNext()
293 fakeIterator, RESUMPTION_TOKEN, mRecorder, TASK_ID, mContext); in testCallsAfterClose()
/packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/data/
DTaskHistoryContract.java33 public static final String TASK_ID = "task_id"; field in TaskHistoryContract.TaskHistoryEntry
51 + TASK_ID
DFederatedTrainingTaskDao.java305 values.put(TaskHistoryContract.TaskHistoryEntry.TASK_ID, taskHistory.getTaskId()); in updateOrInsertTaskHistory()
350 + TaskHistoryContract.TaskHistoryEntry.TASK_ID in getTaskHistory()
/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/scheduling/
DDeleteExpiredJobServiceTest.java86 private static final String TASK_ID = "task_id"; field in DeleteExpiredJobServiceTest
181 .setTaskId(TASK_ID) in deletedExpiredTaskHistory_success()
190 .setTaskId(TASK_ID) in deletedExpiredTaskHistory_success()
197 assertThat(mTrainingTaskDao.getTaskHistoryList(JOB_ID, POPULATION_NAME, TASK_ID)) in deletedExpiredTaskHistory_success()
205 assertThat(mTrainingTaskDao.getTaskHistoryList(JOB_ID, POPULATION_NAME, TASK_ID)) in deletedExpiredTaskHistory_success()
DFederatedComputeJobManagerTest.java85 private static final String TASK_ID = "task-id"; field in FederatedComputeJobManagerTest
110 .setTaskId(TASK_ID)
1441 mTrainingTaskDao.getLatestTaskHistory(JOB_ID1, POPULATION_NAME1, TASK_ID); in testRecordSuccessContribution_noTaskHistory_success()
1453 .setTaskId(TASK_ID) in testRecordSuccessContribution_updateTaskHistory_success()
1463 mTrainingTaskDao.getLatestTaskHistory(JOB_ID1, POPULATION_NAME1, TASK_ID); in testRecordSuccessContribution_updateTaskHistory_success()
/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/http/
DHttpFederatedProtocolTest.java135 private static final String TASK_ID = "task-id"; field in HttpFederatedProtocolTest
1095 .setTaskId(TASK_ID) in createCreateTaskAssignmentResponse()