@@ -13,6 +13,7 @@ import (
13
13
"github.com/reugn/go-quartz/internal/assert"
14
14
"github.com/reugn/go-quartz/internal/mock"
15
15
"github.com/reugn/go-quartz/job"
16
+ "github.com/reugn/go-quartz/matcher"
16
17
"github.com/reugn/go-quartz/quartz"
17
18
)
18
19
@@ -307,6 +308,11 @@ func TestScheduler_JobWithRetries(t *testing.T) {
307
308
)
308
309
err := sched .ScheduleJob (jobDetail , quartz .NewRunOnceTrigger (time .Millisecond ))
309
310
assert .IsNil (t , err )
311
+ err = sched .ScheduleJob (jobDetail , quartz .NewRunOnceTrigger (time .Millisecond ))
312
+ assert .ErrorIs (t , err , quartz .ErrIllegalState )
313
+ jobDetail .Options ().Replace = true
314
+ err = sched .ScheduleJob (jobDetail , quartz .NewRunOnceTrigger (time .Millisecond ))
315
+ assert .IsNil (t , err )
310
316
311
317
assert .Equal (t , funcRetryJob .JobStatus (), job .StatusNA )
312
318
assert .Equal (t , int (atomic .LoadInt32 (& n )), 0 )
@@ -425,6 +431,10 @@ func TestScheduler_PauseResumeErrors(t *testing.T) {
425
431
err = sched .PauseJob (quartz .NewJobKey ("funcJob2" ))
426
432
assert .ErrorIs (t , err , quartz .ErrJobNotFound )
427
433
434
+ assert .Equal (t , len (sched .GetJobKeys (matcher .JobPaused ())), 1 )
435
+ assert .Equal (t , len (sched .GetJobKeys (matcher .JobActive ())), 0 )
436
+ assert .Equal (t , len (sched .GetJobKeys ()), 1 )
437
+
428
438
sched .Stop ()
429
439
}
430
440
0 commit comments