|
1 | 1 | package io.temporal.worker; |
2 | 2 |
|
| 3 | +import static io.temporal.api.enums.v1.VersioningBehavior.VERSIONING_BEHAVIOR_PINNED; |
| 4 | +import static io.temporal.api.workflow.v1.VersioningOverride.PinnedOverrideBehavior.PINNED_OVERRIDE_BEHAVIOR_PINNED; |
3 | 5 | import static org.junit.Assume.assumeTrue; |
4 | 6 |
|
5 | 7 | import com.google.protobuf.ByteString; |
@@ -273,8 +275,7 @@ public void testDynamicWorkflow() { |
273 | 275 | e -> |
274 | 276 | e.getEventType() == EventType.EVENT_TYPE_WORKFLOW_TASK_COMPLETED |
275 | 277 | && e.getWorkflowTaskCompletedEventAttributes().getVersioningBehavior() |
276 | | - == io.temporal.api.enums.v1.VersioningBehavior |
277 | | - .VERSIONING_BEHAVIOR_PINNED)); |
| 278 | + == VERSIONING_BEHAVIOR_PINNED)); |
278 | 279 | } |
279 | 280 |
|
280 | 281 | public static class TestWorkerVersioningMissingAnnotation extends QueueLoop |
@@ -353,8 +354,7 @@ public void testWorkflowsCanUseDefaultVersioningBehaviorWhenSpecified() { |
353 | 354 | e -> |
354 | 355 | e.getEventType() == EventType.EVENT_TYPE_WORKFLOW_TASK_COMPLETED |
355 | 356 | && e.getWorkflowTaskCompletedEventAttributes().getVersioningBehavior() |
356 | | - == io.temporal.api.enums.v1.VersioningBehavior |
357 | | - .VERSIONING_BEHAVIOR_PINNED)); |
| 357 | + == VERSIONING_BEHAVIOR_PINNED)); |
358 | 358 | } |
359 | 359 |
|
360 | 360 | @WorkflowInterface |
@@ -426,9 +426,9 @@ public void testWorkflowsCanUseVersioningOverride() { |
426 | 426 | e.getEventType() == EventType.EVENT_TYPE_WORKFLOW_EXECUTION_STARTED |
427 | 427 | && e.getWorkflowExecutionStartedEventAttributes() |
428 | 428 | .getVersioningOverride() |
| 429 | + .getPinned() |
429 | 430 | .getBehavior() |
430 | | - == io.temporal.api.enums.v1.VersioningBehavior |
431 | | - .VERSIONING_BEHAVIOR_PINNED)); |
| 431 | + == PINNED_OVERRIDE_BEHAVIOR_PINNED)); |
432 | 432 | } |
433 | 433 |
|
434 | 434 | @SuppressWarnings("deprecation") |
|
0 commit comments