diff --git a/task/backend/executor/executor_test.go b/task/backend/executor/executor_test.go
index 20a29b5552..92b6b735b8 100644
--- a/task/backend/executor/executor_test.go
+++ b/task/backend/executor/executor_test.go
@@ -255,11 +255,11 @@ func testExecutorQuerySuccess(t *testing.T, fn createSysFn) {
 	var userID = platformtesting.MustIDFromString("baaaaaaaaaaaaaab")
 	sys := fn()
 	t.Run(sys.name+"/QuerySuccess", func(t *testing.T) {
-		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript)
+		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript, 0)
 		if err != nil {
 			t.Fatal(err)
 		}
-		qr := backend.QueuedRun{TaskID: *tid, RunID: platform.ID(1), Now: 123}
+		qr := backend.QueuedRun{TaskID: tid, RunID: platform.ID(1), Now: 123}
 		rp, err := sys.ex.Execute(context.Background(), qr)
 		if err != nil {
 			t.Fatal(err)
@@ -307,11 +307,11 @@ func testExecutorQueryFailure(t *testing.T, fn createSysFn) {
 	var userID = platformtesting.MustIDFromString("baaaaaaaaaaaaaab")
 	sys := fn()
 	t.Run(sys.name+"/QueryFail", func(t *testing.T) {
-		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript)
+		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript, 0)
 		if err != nil {
 			t.Fatal(err)
 		}
-		qr := backend.QueuedRun{TaskID: *tid, RunID: platform.ID(1), Now: 123}
+		qr := backend.QueuedRun{TaskID: tid, RunID: platform.ID(1), Now: 123}
 		rp, err := sys.ex.Execute(context.Background(), qr)
 		if err != nil {
 			t.Fatal(err)
@@ -335,11 +335,11 @@ func testExecutorPromiseCancel(t *testing.T, fn createSysFn) {
 	var userID = platformtesting.MustIDFromString("baaaaaaaaaaaaaab")
 	sys := fn()
 	t.Run(sys.name+"/PromiseCancel", func(t *testing.T) {
-		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript)
+		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript, 0)
 		if err != nil {
 			t.Fatal(err)
 		}
-		qr := backend.QueuedRun{TaskID: *tid, RunID: platform.ID(1), Now: 123}
+		qr := backend.QueuedRun{TaskID: tid, RunID: platform.ID(1), Now: 123}
 		rp, err := sys.ex.Execute(context.Background(), qr)
 		if err != nil {
 			t.Fatal(err)
@@ -362,11 +362,11 @@ func testExecutorServiceError(t *testing.T, fn createSysFn) {
 	var userID = platformtesting.MustIDFromString("baaaaaaaaaaaaaab")
 	sys := fn()
 	t.Run(sys.name+"/ServiceError", func(t *testing.T) {
-		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript)
+		tid, err := sys.st.CreateTask(context.Background(), orgID, userID, testScript, 0)
 		if err != nil {
 			t.Fatal(err)
 		}
-		qr := backend.QueuedRun{TaskID: *tid, RunID: platform.ID(1), Now: 123}
+		qr := backend.QueuedRun{TaskID: tid, RunID: platform.ID(1), Now: 123}
 
 		var forced = errors.New("forced")
 		sys.svc.FailNextQuery(forced)