diff --git a/src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java b/src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java index 672c2433c..e2a80afbb 100644 --- a/src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java +++ b/src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java @@ -1179,17 +1179,13 @@ public void startWorkflow( .setWorkflowExecution(getExecutionId().getExecution()) .setDomain(getExecutionId().getDomain()) .setWorkflowType(startRequest.getWorkflowType()); - ForkJoinPool.commonPool() - .execute( - () -> { - try { - parent.get().childWorkflowStarted(a); - } catch (EntityNotExistsError | WorkflowExecutionAlreadyCompletedError e) { - // Not a problem. Parent might just close by now. - } catch (BadRequestError | InternalServiceError e) { - log.error("Failure reporting child completion", e); - } - }); + try { + parent.get().childWorkflowStarted(a); + } catch (EntityNotExistsError | WorkflowExecutionAlreadyCompletedError e) { + // Not a problem. Parent might just close by now. + } catch (BadRequestError | InternalServiceError e) { + log.error("Failure reporting child completion", e); + } } }