diff --git a/core/tasks/timeouts/bulk_timeout_test.go b/core/tasks/timeouts/bulk_timeout_test.go index 230b605ea..a2ec71485 100644 --- a/core/tasks/timeouts/bulk_timeout_test.go +++ b/core/tasks/timeouts/bulk_timeout_test.go @@ -25,7 +25,7 @@ func TestBulkTimeout(t *testing.T) { }, }) - assert.Equal(t, map[string]int{"bulk_timeout": 1}, testsuite.FlushTasks(t, rt, []string{"batch", "throttled"})) + assert.Equal(t, map[string]int{"bulk_timeout": 1}, testsuite.FlushTasks(t, rt, "batch", "throttled")) testsuite.AssertContactTasks(t, testdata.Org1, testdata.Cathy, []string{ `{"type":"timeout_event","task":{"session_id":123456,"time":"2024-11-15T13:57:00Z"},"queued_on":"2024-11-15T13:59:00Z"}`, diff --git a/core/tasks/timeouts/cron.go b/core/tasks/timeouts/cron.go index e94e9f670..9a592c091 100644 --- a/core/tasks/timeouts/cron.go +++ b/core/tasks/timeouts/cron.go @@ -15,7 +15,7 @@ import ( ) func init() { - tasks.RegisterCron("sessions_timeouts", NewTimeoutsCron(100, 100)) + tasks.RegisterCron("sessions_timeouts", NewTimeoutsCron(10, 100)) } type timeoutsCron struct {