Reduce threshold for using bulk timeout task to 10

nyaruka · Nov 18, 2024 · ec06eeb · ec06eeb
1 parent 2b33545
commit ec06eeb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -15,7 +15,7 @@ import (
 )
 
 func init() {
-	tasks.RegisterCron("sessions_timeouts", NewTimeoutsCron(100, 100))
+	tasks.RegisterCron("sessions_timeouts", NewTimeoutsCron(10, 100))
 }
 
 type timeoutsCron struct {