final Map<WorkflowInstance, Long> activeStates = componentOpt.isPresent()
? storage.readActiveWorkflowInstances(componentOpt.get())
: storage.readActiveWorkflowInstances();
final Map<RunState, Long> map = replayActiveStates(activeStates, storage, false);
runStates.addAll(
<BUG>map.keySet().stream().map(this::runStateToActiveState).collect(Collectors.toList()));
} catch (IOException e) {</BUG>
throw Throwables.propagate(e);
}
return ActiveStatesPayload.create(runStates);

final Map<WorkflowInstance, Long> activeStates = componentOpt.isPresent()
? storage.readActiveWorkflowInstances(componentOpt.get())
: storage.readActiveWorkflowInstances();
final Map<RunState, Long> map = replayActiveStates(activeStates, storage, false);
runStates.addAll(
map.keySet().stream().map(this::runStateToActiveState).collect(toList()));
} catch (IOException e) {
throw Throwables.propagate(e);
}
return ActiveStatesPayload.create(runStates);
