1010import java .time .Duration ;
1111import java .util .List ;
1212import org .junit .jupiter .api .Test ;
13+ import org .slf4j .Logger ;
14+ import org .slf4j .LoggerFactory ;
1315import software .amazon .awssdk .services .lambda .model .*;
1416
1517class DurableContextTest {
18+ private static final Logger logger = LoggerFactory .getLogger (DurableContextTest .class );
1619
1720 private DurableContext createTestContext () {
1821 var executionOp = Operation .builder ()
@@ -39,6 +42,7 @@ private DurableContext createTestContext(List<Operation> initialOperations) {
3942
4043 @ Test
4144 void testContextCreation () {
45+ logger .info ("testContextCreation" );
4246 var context = createTestContext ();
4347
4448 assertNotNull (context );
@@ -47,6 +51,7 @@ void testContextCreation() {
4751
4852 @ Test
4953 void testGetExecutionContext () {
54+ logger .info ("testGetExecutionContext" );
5055 var context = createTestContext ();
5156
5257 var executionContext = context .getExecutionContext ();
@@ -61,6 +66,7 @@ void testGetExecutionContext() {
6166
6267 @ Test
6368 void testStepExecution () {
69+ logger .info ("testStepExecution" );
6470 var context = createTestContext ();
6571
6672 var result = context .step ("test" , String .class , () -> "Hello World" );
@@ -70,6 +76,7 @@ void testStepExecution() {
7076
7177 @ Test
7278 void testStepReplay () {
79+ logger .info ("testStepReplay" );
7380 // Create context with existing operation
7481 var existingOp = Operation .builder ()
7582 .id ("1" )
@@ -86,6 +93,7 @@ void testStepReplay() {
8693
8794 @ Test
8895 void testStepAsync () throws Exception {
96+ logger .info ("testStepAsync" );
8997 var context = createTestContext ();
9098
9199 var future = context .stepAsync ("async-test" , String .class , () -> "Async Result" );
@@ -96,6 +104,7 @@ void testStepAsync() throws Exception {
96104
97105 @ Test
98106 void testStepAsyncReplay () throws Exception {
107+ logger .info ("testStepAsyncReplay" );
99108 // Create context with existing operation
100109 var existingOp = Operation .builder ()
101110 .id ("1" )
@@ -112,6 +121,7 @@ void testStepAsyncReplay() throws Exception {
112121
113122 @ Test
114123 void testWait () {
124+ logger .info ("testWait" );
115125 var context = createTestContext ();
116126
117127 // Wait should throw SuspendExecutionException
@@ -122,6 +132,7 @@ void testWait() {
122132
123133 @ Test
124134 void testWaitReplay () {
135+ logger .info ("testWaitReplay" );
125136 // Create context with completed wait operation
126137 var existingOp =
127138 Operation .builder ().id ("1" ).status (OperationStatus .SUCCEEDED ).build ();
@@ -135,6 +146,7 @@ void testWaitReplay() {
135146
136147 @ Test
137148 void testCombinedSyncAsyncWait () throws Exception {
149+ logger .info ("testCombinedSyncAsyncWait" );
138150 var context = createTestContext ();
139151
140152 // Execute sync step
@@ -153,6 +165,7 @@ void testCombinedSyncAsyncWait() throws Exception {
153165
154166 @ Test
155167 void testCombinedReplay () throws Exception {
168+ logger .info ("testCombinedReplay" );
156169 // Create context with all operations completed
157170 var syncOp = Operation .builder ()
158171 .id ("1" )
@@ -183,6 +196,7 @@ void testCombinedReplay() throws Exception {
183196
184197 @ Test
185198 void testNamedWait () {
199+ logger .info ("testNamedWait" );
186200 var ctx = createTestContext ();
187201
188202 // Named wait should throw SuspendExecutionException
@@ -203,6 +217,7 @@ void testNamedWait() {
203217
204218 @ Test
205219 void testStepWithTypeToken () {
220+ logger .info ("testStepWithTypeToken" );
206221 var context = createTestContext ();
207222
208223 List <String > result = context .step ("test-list" , new TypeToken <List <String >>() {}, () -> List .of ("a" , "b" , "c" ));
@@ -214,6 +229,7 @@ void testStepWithTypeToken() {
214229
215230 @ Test
216231 void testStepWithTypeTokenReplay () {
232+ logger .info ("testStepWithTypeTokenReplay" );
217233 // Create context with existing operation
218234 var existingOp = Operation .builder ()
219235 .id ("1" )
@@ -235,6 +251,7 @@ void testStepWithTypeTokenReplay() {
235251
236252 @ Test
237253 void testStepWithTypeTokenAndConfig () {
254+ logger .info ("testStepWithTypeTokenAndConfig" );
238255 var context = createTestContext ();
239256
240257 List <Integer > result = context .step (
@@ -252,6 +269,7 @@ void testStepWithTypeTokenAndConfig() {
252269
253270 @ Test
254271 void testStepAsyncWithTypeToken () throws Exception {
272+ logger .info ("testStepAsyncWithTypeToken" );
255273 var context = createTestContext ();
256274
257275 DurableFuture <List <String >> future =
@@ -265,6 +283,7 @@ void testStepAsyncWithTypeToken() throws Exception {
265283
266284 @ Test
267285 void testStepAsyncWithTypeTokenReplay () throws Exception {
286+ logger .info ("testStepAsyncWithTypeTokenReplay" );
268287 // Create context with existing operation
269288 var existingOp = Operation .builder ()
270289 .id ("1" )
@@ -287,6 +306,7 @@ void testStepAsyncWithTypeTokenReplay() throws Exception {
287306
288307 @ Test
289308 void testStepAsyncWithTypeTokenAndConfig () throws Exception {
309+ logger .info ("testStepAsyncWithTypeTokenAndConfig" );
290310 var context = createTestContext ();
291311
292312 DurableFuture <List <Integer >> future = context .stepAsync (
0 commit comments