|
3 | 3 |
|
4 | 4 | package com.microsoft.durabletask; |
5 | 5 |
|
6 | | -import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.*; |
| 6 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.CreateInstanceRequest; |
| 7 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.CreateInstanceResponse; |
| 8 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.CreateTaskHubRequest; |
| 9 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.CreateTaskHubResponse; |
| 10 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.DeleteTaskHubRequest; |
| 11 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.DeleteTaskHubResponse; |
| 12 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.GetInstanceRequest; |
| 13 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.GetInstanceResponse; |
| 14 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.PurgeInstancesRequest; |
| 15 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.PurgeInstancesResponse; |
| 16 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.QueryInstancesRequest; |
| 17 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.QueryInstancesResponse; |
| 18 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.RaiseEventRequest; |
| 19 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.RaiseEventResponse; |
| 20 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.ResumeRequest; |
| 21 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.ResumeResponse; |
| 22 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.RewindInstanceRequest; |
| 23 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.RewindInstanceResponse; |
| 24 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.SuspendRequest; |
| 25 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.SuspendResponse; |
| 26 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.TerminateRequest; |
| 27 | +import com.microsoft.durabletask.implementation.protobuf.OrchestratorService.TerminateResponse; |
7 | 28 | import com.microsoft.durabletask.implementation.protobuf.TaskHubSidecarServiceGrpc; |
8 | 29 |
|
9 | 30 | import io.grpc.*; |
@@ -296,7 +317,7 @@ public void purgeInstances(PurgeInstancesRequest request, StreamObserver<PurgeIn |
296 | 317 | }); |
297 | 318 |
|
298 | 319 | PurgeInstanceCriteria criteria = new PurgeInstanceCriteria() |
299 | | - .setCreatedTimeFrom(Instant.now().minus(Duration.ofDays(1))); |
| 320 | + .setCreatedTimeFrom(Instant.parse("2026-01-01T00:00:00Z")); |
300 | 321 |
|
301 | 322 | TimeoutException ex = assertThrows(TimeoutException.class, () -> |
302 | 323 | client.purgeInstances(criteria)); |
@@ -353,7 +374,7 @@ public void purgeInstances(PurgeInstancesRequest request, StreamObserver<PurgeIn |
353 | 374 | }); |
354 | 375 |
|
355 | 376 | PurgeInstanceCriteria criteria = new PurgeInstanceCriteria() |
356 | | - .setCreatedTimeFrom(Instant.now().minus(Duration.ofDays(1))); |
| 377 | + .setCreatedTimeFrom(Instant.parse("2026-01-01T00:00:00Z")); |
357 | 378 |
|
358 | 379 | NoSuchElementException ex = assertThrows(NoSuchElementException.class, () -> |
359 | 380 | client.purgeInstances(criteria)); |
|
0 commit comments