Skip to content

Commit

Permalink
#4682 PlanB State Store
Browse files Browse the repository at this point in the history
  • Loading branch information
stroomdev66 committed Jan 10, 2025
1 parent 445a43c commit 6df4d1b
Showing 1 changed file with 7 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -241,6 +241,7 @@ protected EffectiveMetaSet create(final EffectiveStreamKey key) {
pipelineStore,
new MockSecurityContext(),
taskContextFactory,
null,
null);

Map<RefStreamDefinition, Runnable> mockLoaderActionsMap = new HashMap<>();
Expand Down Expand Up @@ -344,6 +345,7 @@ protected EffectiveMetaSet create(final EffectiveStreamKey key) {
pipelineStore,
new MockSecurityContext(),
taskContextFactory,
null,
null);

Map<RefStreamDefinition, Runnable> mockLoaderActionsMap = new HashMap<>();
Expand Down Expand Up @@ -492,9 +494,9 @@ private void addRangeValueDataToMockReferenceDataLoader(
private StringValue buildValue(MapDefinition mapDefinition, String value) {
return StringValue.of(
mapDefinition.getRefStreamDefinition().getPipelineDocRef().getUuid() + "|" +
mapDefinition.getRefStreamDefinition().getStreamId() + "|" +
mapDefinition.getMapName() + "|" +
value
mapDefinition.getRefStreamDefinition().getStreamId() + "|" +
mapDefinition.getMapName() + "|" +
value
);
}

Expand Down Expand Up @@ -591,6 +593,7 @@ protected EffectiveMetaSet create(final EffectiveStreamKey key) {
pipelineStore,
new MockSecurityContext(),
taskContextFactory,
null,
null);

Map<RefStreamDefinition, Runnable> mockLoaderActionsMap = new HashMap<>();
Expand Down Expand Up @@ -674,6 +677,7 @@ protected EffectiveMetaSet create(final EffectiveStreamKey key) {
pipelineStore,
new MockSecurityContext(),
taskContextFactory,
null,
null);

Map<RefStreamDefinition, Runnable> mockLoaderActionsMap = new HashMap<>();
Expand Down

0 comments on commit 6df4d1b

Please sign in to comment.