Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix(platform/task/backend/executor): porting tests to uint64 IDs

pull/10616/head
Leonardo Di Donato 2018-09-28 15:30:06 +02:00 committed by Chris Goller
parent 5db4276a71
commit 5d4d8a7c04
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
task/backend/executor/executor_test.go
View File

@ -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)