Skip to content

Commit a78fa31

Browse files
Check activity options
1 parent 0724538 commit a78fa31

1 file changed

Lines changed: 7 additions & 4 deletions

File tree

temporal-test-server/src/test/java/io/temporal/testserver/functional/DescribeWorkflowExecutionTest.java

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,7 @@ private void testKilledWorkflow(
311311

312312
PendingActivityInfo actual = asserter.getActual().getPendingActivities(0);
313313

314-
PendingActivityInfo expected =
314+
PendingActivityInfo.Builder expected =
315315
PendingActivityInfo.newBuilder()
316316
.setActivityId(actual.getActivityId())
317317
.setActivityType(ActivityType.newBuilder().setName("TestDescribeActivity").build())
@@ -325,10 +325,13 @@ private void testKilledWorkflow(
325325
.setExpirationTime(actual.getExpirationTime())
326326
// this ends up being a dummy value, but if it weren't, we still wouldn't expect to know
327327
// it.
328-
.setLastWorkerIdentity(actual.getLastWorkerIdentity())
329-
.build();
328+
.setLastWorkerIdentity(actual.getLastWorkerIdentity());
329+
if (actual.hasActivityOptions()) {
330+
// If the activity options are present, we can assert them
331+
expected.setActivityOptions(actual.getActivityOptions());
332+
}
330333

331-
Assert.assertEquals("PendingActivityInfo should match", expected, actual);
334+
Assert.assertEquals("PendingActivityInfo should match", expected.build(), actual);
332335
}
333336

334337
@Test

0 commit comments

Comments
 (0)