@@ -1262,7 +1262,7 @@ func TestQueuePosition(t *testing.T) {
1262
1262
Provisioners : []database.ProvisionerType {database .ProvisionerTypeEcho },
1263
1263
// Ensure the `tags` field is NOT NULL for the default provisioner;
1264
1264
// otherwise, it won't be able to pick up any jobs.
1265
- Tags : database.StringMap {"a" : "1" },
1265
+ Tags : database.StringMap {},
1266
1266
})
1267
1267
1268
1268
queued , err := db .GetProvisionerJobsByIDsWithQueuePosition (ctx , jobIDs )
@@ -2421,7 +2421,6 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2421
2421
now := dbtime .Now ()
2422
2422
ctx := testutil .Context (t , testutil .WaitShort )
2423
2423
2424
- defaultTags := database.StringMap {"a" : "1" }
2425
2424
// Create the following provisioner jobs:
2426
2425
allJobs := []database.ProvisionerJob {
2427
2426
// Pending. This will be the last in the queue because
@@ -2432,7 +2431,9 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2432
2431
CanceledAt : sql.NullTime {},
2433
2432
CompletedAt : sql.NullTime {},
2434
2433
Error : sql.NullString {},
2435
- Tags : defaultTags ,
2434
+ // Ensure the `tags` field is NOT NULL for both provisioner jobs and provisioner daemons;
2435
+ // otherwise, provisioner daemons won't be able to pick up any jobs.
2436
+ Tags : database.StringMap {},
2436
2437
}),
2437
2438
2438
2439
// Another pending. This will come first in the queue
@@ -2443,7 +2444,7 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2443
2444
CanceledAt : sql.NullTime {},
2444
2445
CompletedAt : sql.NullTime {},
2445
2446
Error : sql.NullString {},
2446
- Tags : defaultTags ,
2447
+ Tags : database. StringMap {} ,
2447
2448
}),
2448
2449
2449
2450
// Running
@@ -2453,7 +2454,7 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2453
2454
CanceledAt : sql.NullTime {},
2454
2455
CompletedAt : sql.NullTime {},
2455
2456
Error : sql.NullString {},
2456
- Tags : defaultTags ,
2457
+ Tags : database. StringMap {} ,
2457
2458
}),
2458
2459
2459
2460
// Succeeded
@@ -2463,7 +2464,7 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2463
2464
CanceledAt : sql.NullTime {},
2464
2465
CompletedAt : sql.NullTime {Valid : true , Time : now },
2465
2466
Error : sql.NullString {},
2466
- Tags : defaultTags ,
2467
+ Tags : database. StringMap {} ,
2467
2468
}),
2468
2469
2469
2470
// Canceling
@@ -2473,7 +2474,7 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2473
2474
CanceledAt : sql.NullTime {Valid : true , Time : now },
2474
2475
CompletedAt : sql.NullTime {},
2475
2476
Error : sql.NullString {},
2476
- Tags : defaultTags ,
2477
+ Tags : database. StringMap {} ,
2477
2478
}),
2478
2479
2479
2480
// Canceled
@@ -2483,7 +2484,7 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2483
2484
CanceledAt : sql.NullTime {Valid : true , Time : now },
2484
2485
CompletedAt : sql.NullTime {Valid : true , Time : now },
2485
2486
Error : sql.NullString {},
2486
- Tags : defaultTags ,
2487
+ Tags : database. StringMap {} ,
2487
2488
}),
2488
2489
2489
2490
// Failed
@@ -2493,15 +2494,15 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_MixedStatuses(t *testing.T) {
2493
2494
CanceledAt : sql.NullTime {},
2494
2495
CompletedAt : sql.NullTime {},
2495
2496
Error : sql.NullString {String : "failed" , Valid : true },
2496
- Tags : defaultTags ,
2497
+ Tags : database. StringMap {} ,
2497
2498
}),
2498
2499
}
2499
2500
2500
2501
// Create default provisioner daemon:
2501
2502
dbgen .ProvisionerDaemon (t , db , database.ProvisionerDaemon {
2502
2503
Name : "default_provisioner" ,
2503
2504
Provisioners : []database.ProvisionerType {database .ProvisionerTypeEcho },
2504
- Tags : defaultTags ,
2505
+ Tags : database. StringMap {} ,
2505
2506
})
2506
2507
2507
2508
// Assert invariant: the jobs are in the expected order
@@ -2561,45 +2562,46 @@ func TestGetProvisionerJobsByIDsWithQueuePosition_OrderValidation(t *testing.T)
2561
2562
now := dbtime .Now ()
2562
2563
ctx := testutil .Context (t , testutil .WaitShort )
2563
2564
2564
- defaultTags := database.StringMap {"a" : "1" }
2565
2565
// Create the following provisioner jobs:
2566
2566
allJobs := []database.ProvisionerJob {
2567
2567
dbgen .ProvisionerJob (t , db , nil , database.ProvisionerJob {
2568
2568
CreatedAt : now .Add (- 4 * time .Minute ),
2569
- Tags : defaultTags ,
2569
+ // Ensure the `tags` field is NOT NULL for both provisioner jobs and provisioner daemons;
2570
+ // otherwise, provisioner daemons won't be able to pick up any jobs.
2571
+ Tags : database.StringMap {},
2570
2572
}),
2571
2573
2572
2574
dbgen .ProvisionerJob (t , db , nil , database.ProvisionerJob {
2573
2575
CreatedAt : now .Add (- 5 * time .Minute ),
2574
- Tags : defaultTags ,
2576
+ Tags : database. StringMap {} ,
2575
2577
}),
2576
2578
2577
2579
dbgen .ProvisionerJob (t , db , nil , database.ProvisionerJob {
2578
2580
CreatedAt : now .Add (- 6 * time .Minute ),
2579
- Tags : defaultTags ,
2581
+ Tags : database. StringMap {} ,
2580
2582
}),
2581
2583
2582
2584
dbgen .ProvisionerJob (t , db , nil , database.ProvisionerJob {
2583
2585
CreatedAt : now .Add (- 3 * time .Minute ),
2584
- Tags : defaultTags ,
2586
+ Tags : database. StringMap {} ,
2585
2587
}),
2586
2588
2587
2589
dbgen .ProvisionerJob (t , db , nil , database.ProvisionerJob {
2588
2590
CreatedAt : now .Add (- 2 * time .Minute ),
2589
- Tags : defaultTags ,
2591
+ Tags : database. StringMap {} ,
2590
2592
}),
2591
2593
2592
2594
dbgen .ProvisionerJob (t , db , nil , database.ProvisionerJob {
2593
2595
CreatedAt : now .Add (- 1 * time .Minute ),
2594
- Tags : defaultTags ,
2596
+ Tags : database. StringMap {} ,
2595
2597
}),
2596
2598
}
2597
2599
2598
2600
// Create default provisioner daemon:
2599
2601
dbgen .ProvisionerDaemon (t , db , database.ProvisionerDaemon {
2600
2602
Name : "default_provisioner" ,
2601
2603
Provisioners : []database.ProvisionerType {database .ProvisionerTypeEcho },
2602
- Tags : defaultTags ,
2604
+ Tags : database. StringMap {} ,
2603
2605
})
2604
2606
2605
2607
// Assert invariant: the jobs are in the expected order
0 commit comments