Test reliability - TestResyncFailed: Cancel flow before tear down

pfcoperez · pfcoperez · commit c184089eb1b0 · 2026-04-08T17:56:05.000+02:00
diff --git a/flow/e2e/api_test.go b/flow/e2e/api_test.go
@@ -1445,6 +1445,9 @@ func (s APITestSuite) TestResyncFailed() {
 	env, err = GetPeerflow(s.t.Context(), s.catalog, tc, flowConnConfig.FlowJobName)
 	require.NoError(s.t, err)
 	EnvWaitForCount(env, s.ch, "resync should have 2 rows", dstTableName, cols, 2)
+
+	env.Cancel(s.t.Context())
+	RequireEnvCanceled(s.t, env)
 }
 
 func (s APITestSuite) TestDropCompleted() {

Original file line number	Diff line number	Diff line change
`@@ -1445,6 +1445,9 @@ func (s APITestSuite) TestResyncFailed() {`
`1445`	`1445`	`env, err = GetPeerflow(s.t.Context(), s.catalog, tc, flowConnConfig.FlowJobName)`
`1446`	`1446`	`require.NoError(s.t, err)`
`1447`	`1447`	`EnvWaitForCount(env, s.ch, "resync should have 2 rows", dstTableName, cols, 2)`
	`1448`	`+`
	`1449`	`+ env.Cancel(s.t.Context())`
	`1450`	`+ RequireEnvCanceled(s.t, env)`
`1448`	`1451`	`}`
`1449`	`1452`
`1450`	`1453`	`func (s APITestSuite) TestDropCompleted() {`