File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -76,12 +76,15 @@ def perform
76
76
Jobs ::GenericEnqueuer . reset! # Ensure no previous state interferes
77
77
78
78
pollable_job = Jobs ::Enqueuer . new ( { queue : Jobs ::Queues . generic , priority : 22 } ) . enqueue_pollable ( FakeJob . new )
79
- expect ( Delayed ::Job . where ( guid : PollableJobModel . first . delayed_job_guid ) . first [ :priority ] ) . to eq ( 42 )
79
+ first_delayed_job_guid = pollable_job . delayed_job_guid
80
+ expect ( Delayed ::Job . where ( guid : first_delayed_job_guid ) . first [ :priority ] ) . to eq ( 42 )
80
81
81
82
execute_all_jobs ( expected_successes : 1 , expected_failures : 0 , jobs_to_execute : 1 )
82
83
83
- expect ( Delayed ::Job . where ( guid : PollableJobModel . first . delayed_job_guid ) . first [ :priority ] ) . to eq ( 42 )
84
- expect ( PollableJobModel . first . delayed_job_guid ) . not_to eq ( pollable_job . delayed_job_guid )
84
+ pollable_job . reload
85
+ second_delayed_job_guid = pollable_job . delayed_job_guid
86
+ expect ( Delayed ::Job . where ( guid : second_delayed_job_guid ) . first [ :priority ] ) . to eq ( 42 )
87
+ expect ( first_delayed_job_guid ) . not_to eq ( second_delayed_job_guid )
85
88
end
86
89
87
90
it 'waits for the polling interval' do
You can’t perform that action at this time.
0 commit comments