@Test
public void run_parentContextProvided_contextHasParentContext() {

    // given
    CurrentExecutionContext context = new SagaExecutionContext();
    ExecutionContext parentContext = mock(ExecutionContext.class);
    SagaEnvironment env = SagaEnvironment.create(timeoutManager, storage, createContextProvider(context), Sets.newHashSet(module),
            Sets.newHashSet(interceptor), instanceResolver, DefaultModuleCoordinator::new);
    sut = new SagaExecutionTask(env, invoker, theMessage, Collections.EMPTY_MAP, parentContext);
    // when
    sut.run();
    // then
    assertThat("Expected header value to be part of context.", context.parentContext(), sameInstance(parentContext));
}