Skip to content

Commit 6a00157

Browse files
committed
fixup! chore: filter workspaces at router and batchrouter - like destinationIDs
1 parent f54545c commit 6a00157

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

processor/processor_isolation_test.go

+5-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,11 @@ func TestProcessorIsolation(t *testing.T) {
4848
pipelinesPerPartition = 3
4949
)
5050

51-
for _, isolationMode := range []isolation.Mode{isolation.ModeNone, isolation.ModeWorkspace, isolation.ModeSource} {
51+
for _, isolationMode := range []isolation.Mode{
52+
isolation.ModeNone,
53+
isolation.ModeWorkspace,
54+
isolation.ModeSource,
55+
} {
5256
t.Run(fmt.Sprintf("%s isolation", isolationMode), func(t *testing.T) {
5357
t.Run("1 worker", func(t *testing.T) {
5458
ProcIsolationScenario(t, NewProcIsolationScenarioSpec(isolationMode, workspaces, jobsPerWorkspace, 1))

processor/testdata/procIsolationTestTemplate.json.tpl

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
"webhookMethod": "POST"
2525
},
2626
"secretConfig": {},
27-
"id": "{{$.destinationId}}",
27+
"id": "{{$.destinationId}}-{{$index}}",
2828
"name": "Des WebHook Integration Test 1",
2929
"enabled": true,
3030
"workspaceId": "{{$workspace}}",

0 commit comments

Comments
 (0)