enable existing tasks to be deferred

xh3b4sd · Oct 13, 2024 · 5aaee91 · 5aaee91
1 parent 2d93e20
commit 5aaee91
Show file tree

Hide file tree

Showing 14 changed files with 432 additions and 61 deletions.
diff --git a/conformance/delete_cron_redis_test.go b/conformance/delete_cron_redis_test.go
@@ -12,26 +12,14 @@ import (
 	"github.com/xh3b4sd/rescue/task"
 )
 
-func Test_Engine_Delete_Cron(t *testing.T) {
+func Test_Engine_Delete_Cron_Aevery(t *testing.T) {
 	var err error
 
-	var red redigo.Interface
-	{
-		red = redigo.Default()
-	}
-
-	{
-		err = red.Purge()
-		if err != nil {
-			t.Fatal(err)
-		}
-	}
-
 	var eon rescue.Interface
 	{
 		eon = engine.New(engine.Config{
 			Logger: logger.Fake(),
-			Redigo: red,
+			Redigo: prgAll(redigo.Default()),
 		})
 	}
 

diff --git a/conformance/delete_gate_redis_test.go b/conformance/delete_gate_redis_test.go
@@ -15,23 +15,11 @@ import (
 func Test_Engine_Delete_Gate(t *testing.T) {
 	var err error
 
-	var red redigo.Interface
-	{
-		red = redigo.Default()
-	}
-
-	{
-		err = red.Purge()
-		if err != nil {
-			t.Fatal(err)
-		}
-	}
-
 	var eon rescue.Interface
 	{
 		eon = engine.New(engine.Config{
 			Logger: logger.Fake(),
-			Redigo: red,
+			Redigo: prgAll(redigo.Default()),
 		})
 	}