From d22795aafbc9b1069e2c3de4b8b3c96bf05f9723 Mon Sep 17 00:00:00 2001 From: YangKeao Date: Sun, 29 Jan 2023 14:05:54 +0800 Subject: [PATCH] ttl: use a standalone manager in TriggerScanTask test (#40816) close pingcap/tidb#40811 --- ttl/ttlworker/job_manager_integration_test.go | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/ttl/ttlworker/job_manager_integration_test.go b/ttl/ttlworker/job_manager_integration_test.go index 11b4a1b6e8dee..82b107b976b70 100644 --- a/ttl/ttlworker/job_manager_integration_test.go +++ b/ttl/ttlworker/job_manager_integration_test.go @@ -434,17 +434,23 @@ func TestTriggerScanTask(t *testing.T) { store, dom := testkit.CreateMockStoreAndDomain(t) tk := testkit.NewTestKit(t, store) sessionFactory := sessionFactory(t, store) - now := time.Now() - se := sessionFactory() - m := dom.TTLJobManager() - m.TaskManager().ResizeWorkersWithSysVar() - nCli := m.GetNotificationCli() + + waitAndStopTTLManager(t, dom) tk.MustExec("create table test.t (id int, created_at datetime) ttl = `created_at` + interval 1 minute ttl_job_interval = '1m'") + + m := ttlworker.NewJobManager("manager-1", nil, store, nil) require.NoError(t, m.InfoSchemaCache().Update(se)) + m.TaskManager().ResizeWorkersWithSysVar() + m.Start() + defer func() { + m.Stop() + require.NoError(t, m.WaitStopped(context.Background(), time.Second*10)) + }() + nCli := m.GetNotificationCli() wg := &sync.WaitGroup{} wg.Add(1) go func() {