Skip to content

Commit 7d1da80

Browse files
blakerouseblakerouse
committed
Fix unit tests.
1 parent d8da230 commit 7d1da80

1 file changed

Lines changed: 7 additions & 7 deletions

File tree

  • x-pack/elastic-agent/pkg/agent/application/pipeline/router

‎x-pack/elastic-agent/pkg/agent/application/pipeline/router/router_test.go‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -87,14 +87,14 @@ func TestRouter(t *testing.T) {
8787
})
8888

8989
assertOps(t, []event{
90-
e(pipeline.DefaultRK, createOp),
91-
e(pipeline.DefaultRK, executeOp),
92-
9390
e(k1, createOp),
9491
e(k1, executeOp),
9592

9693
e(k2, createOp),
9794
e(k2, executeOp),
95+
96+
e(pipeline.DefaultRK, createOp),
97+
e(pipeline.DefaultRK, executeOp),
9898
}, recorder.events)
9999

100100
recorder.reset()
@@ -108,9 +108,9 @@ func TestRouter(t *testing.T) {
108108
e(nk, createOp),
109109
e(nk, executeOp),
110110

111-
e(pipeline.DefaultRK, closeOp),
112111
e(k1, closeOp),
113112
e(k2, closeOp),
113+
e(pipeline.DefaultRK, closeOp),
114114
}, recorder.events)
115115
})
116116

@@ -152,22 +152,22 @@ func TestRouter(t *testing.T) {
152152
})
153153

154154
assertOps(t, []event{
155-
e(pipeline.DefaultRK, createOp),
156-
e(pipeline.DefaultRK, executeOp),
157155
e(k1, createOp),
158156
e(k1, executeOp),
159157
e(k2, createOp),
160158
e(k2, executeOp),
159+
e(pipeline.DefaultRK, createOp),
160+
e(pipeline.DefaultRK, executeOp),
161161
}, recorder.events)
162162

163163
recorder.reset()
164164

165165
r.Route("hello-2", map[pipeline.RoutingKey][]program.Program{})
166166

167167
assertOps(t, []event{
168-
e(pipeline.DefaultRK, closeOp),
169168
e(k1, closeOp),
170169
e(k2, closeOp),
170+
e(pipeline.DefaultRK, closeOp),
171171
}, recorder.events)
172172
})
173173
}

0 commit comments

Comments
 (0)