File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
lib/solid_queue/scheduler Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -41,6 +41,7 @@ def task_keys
41
41
42
42
private
43
43
def persist_tasks
44
+ SolidQueue ::RecurringTask . static . where . not ( key : task_keys ) . delete_all
44
45
SolidQueue ::RecurringTask . create_or_update_all configured_tasks
45
46
end
46
47
Original file line number Diff line number Diff line change @@ -64,13 +64,13 @@ class RecurringTasksTest < ActiveSupport::TestCase
64
64
scheduler1 = SolidQueue ::Scheduler . new ( recurring_tasks : another_task ) . tap ( &:start )
65
65
wait_for_registered_processes ( 6 , timeout : 1 . second )
66
66
67
- assert_recurring_tasks configured_task . merge ( another_task )
67
+ assert_recurring_tasks another_task
68
68
69
69
updated_task = { example_task : { class : "AddToBufferJob" , schedule : "every minute" } }
70
70
scheduler2 = SolidQueue ::Scheduler . new ( recurring_tasks : updated_task ) . tap ( &:start )
71
71
wait_for_registered_processes ( 7 , timeout : 1 . second )
72
72
73
- assert_recurring_tasks configured_task . merge ( updated_task )
73
+ assert_recurring_tasks updated_task
74
74
75
75
terminate_process ( @pid )
76
76
scheduler1 . stop
You can’t perform that action at this time.
0 commit comments