@@ -412,15 +412,15 @@ public void testParentChildFork() {
412412
413413 assertEquals (2 , impl .step1Count ) ;
414414 assertEquals (2 , impl .step2Count ) ;
415- assertEquals (2 , impl .child1Count ) ;
416- assertEquals (2 , impl .child2Count ) ;
415+ assertEquals (1 , impl .child1Count ) ;
416+ assertEquals (1 , impl .child2Count ) ;
417417 assertEquals (2 , impl .step5Count ) ;
418418
419419 List <StepInfo > steps = systemDatabase .listWorkflowSteps (rstatHandle .getWorkflowId ()) ;
420420 assertEquals (5 , steps .size ()) ;
421421
422- assertTrue (! stepsRun0 .get (2 ).getChildWorkflowId ().equals (steps .get (2 ).getChildWorkflowId ()));
423- assertTrue (! stepsRun0 .get (3 ).getChildWorkflowId ().equals (steps .get (3 ).getChildWorkflowId ()));
422+ assertTrue (stepsRun0 .get (2 ).getChildWorkflowId ().equals (steps .get (2 ).getChildWorkflowId ()));
423+ assertTrue (stepsRun0 .get (3 ).getChildWorkflowId ().equals (steps .get (3 ).getChildWorkflowId ()));
424424
425425 logger .info ("First execution done starting 2nd fork" );
426426
@@ -432,8 +432,8 @@ public void testParentChildFork() {
432432
433433 assertEquals (2 , impl .step1Count ) ;
434434 assertEquals (2 , impl .step2Count ) ;
435- assertEquals (2 , impl .child1Count ) ;
436- assertEquals (3 , impl .child2Count ) ;
435+ assertEquals (1 , impl .child1Count ) ;
436+ assertEquals (1 , impl .child2Count ) ;
437437 assertEquals (3 , impl .step5Count ) ;
438438
439439 steps = systemDatabase .listWorkflowSteps (rstatHandle .getWorkflowId ()) ;
@@ -442,7 +442,7 @@ public void testParentChildFork() {
442442 logger .info (stepsRun0 .get (2 ).getChildWorkflowId () ) ;
443443 logger .info (steps .get (2 ).getChildWorkflowId ()) ;
444444 assertTrue (stepsRun0 .get (2 ).getChildWorkflowId ().equals (steps .get (2 ).getChildWorkflowId ()));
445- assertTrue (! stepsRun0 .get (3 ).getChildWorkflowId ().equals (steps .get (3 ).getChildWorkflowId ()));
445+ assertTrue (stepsRun0 .get (3 ).getChildWorkflowId ().equals (steps .get (3 ).getChildWorkflowId ()));
446446
447447 logger .info ("First execution done starting 2nd fork" );
448448
@@ -454,8 +454,8 @@ public void testParentChildFork() {
454454
455455 assertEquals (2 , impl .step1Count ) ;
456456 assertEquals (2 , impl .step2Count ) ;
457- assertEquals (2 , impl .child1Count ) ;
458- assertEquals (3 , impl .child2Count ) ;
457+ assertEquals (1 , impl .child1Count ) ;
458+ assertEquals (1 , impl .child2Count ) ;
459459 assertEquals (4 , impl .step5Count ) ;
460460
461461 steps = systemDatabase .listWorkflowSteps (rstatHandle .getWorkflowId ()) ;
0 commit comments