diff options
Diffstat (limited to 'spec/services/ci/pipeline_schedules/calculate_next_run_service_spec.rb')
| -rw-r--r-- | spec/services/ci/pipeline_schedules/calculate_next_run_service_spec.rb | 107 |
1 files changed, 107 insertions, 0 deletions
diff --git a/spec/services/ci/pipeline_schedules/calculate_next_run_service_spec.rb b/spec/services/ci/pipeline_schedules/calculate_next_run_service_spec.rb new file mode 100644 index 00000000000..182c5bebbc1 --- /dev/null +++ b/spec/services/ci/pipeline_schedules/calculate_next_run_service_spec.rb @@ -0,0 +1,107 @@ +# frozen_string_literal: true +# rubocop:disable Layout/LineLength +require 'spec_helper' + +RSpec.describe Ci::PipelineSchedules::CalculateNextRunService, feature_category: :continuous_integration do + let_it_be(:project) { create(:project, :public, :repository) } + + describe '#execute' do + using RSpec::Parameterized::TableSyntax + + let(:run_service) do + described_class.new(project).execute(pipeline_schedule, + fallback_method: pipeline_schedule.method(:calculate_next_run_at)) + end + + let(:pipeline_schedule) { create(:ci_pipeline_schedule, cron: schedule_cron) } + let(:daily_limit_of_144_runs) { 1.day / 10.minutes } + let(:daily_limit_of_24_runs) { 1.day / 1.hour } + + before do + allow(Settings).to receive(:cron_jobs) { { 'pipeline_schedule_worker' => { 'cron' => worker_cron } } } + create(:plan_limits, :default_plan, ci_daily_pipeline_schedule_triggers: plan_limit) if plan_limit + end + + context "when there is invalid or no plan limits" do + where(:worker_cron, :schedule_cron, :plan_limit, :now, :expected_result) do + '0 1 2 3 *' | '0 1 * * *' | nil | Time.zone.local(2021, 3, 2, 1, 0) | Time.zone.local(2022, 3, 2, 1, 0) + '*/5 * * * *' | '*/1 * * * *' | nil | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 11, 5) + '*/5 * * * *' | '0 * * * *' | nil | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 12, 5) + # 1.day / 2.hours => 12 times a day and it is invalid because there is a minimum for plan limits. + # See: https://docs.gitlab.com/ee/administration/instance_limits.html#limit-the-number-of-pipelines-created-by-a-pipeline-schedule-per-day + '*/5 * * * *' | '0 * * * *' | 1.day / 2.hours | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 12, 5) + end + + with_them do + it 'calls fallback method to get next_run_at' do + travel_to(now) do + expect(pipeline_schedule).to receive(:calculate_next_run_at).and_call_original + + result = run_service + + expect(result).to eq(expected_result) + end + end + end + end + + context "when the workers next run matches schedule's earliest run" do + where(:worker_cron, :schedule_cron, :plan_limit, :now, :expected_result) do + '*/5 * * * *' | '0 * * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 12, 0) + '*/5 * * * *' | '*/5 * * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 11, 10) + '*/5 * * * *' | '0 1 * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 27, 1, 0) | Time.zone.local(2021, 5, 28, 1, 0) + '*/5 * * * *' | '0 2 * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 27, 1, 0) | Time.zone.local(2021, 5, 27, 2, 0) + '*/5 * * * *' | '0 3 * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 27, 1, 0) | Time.zone.local(2021, 5, 27, 3, 0) + '*/5 * * * *' | '0 1 1 * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 1, 1, 0) | Time.zone.local(2021, 6, 1, 1, 0) + '*/9 * * * *' | '0 1 1 * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 1, 1, 9) | Time.zone.local(2021, 6, 1, 1, 0) + '*/5 * * * *' | '45 21 1 2 *' | daily_limit_of_144_runs | Time.zone.local(2021, 2, 1, 21, 45) | Time.zone.local(2022, 2, 1, 21, 45) + end + + with_them do + it 'calculates the next_run_at to be earliest point of match' do + travel_to(now) do + result = run_service + + expect(result).to eq(expected_result) + end + end + end + end + + context "when next_run_at is restricted by plan limit" do + where(:worker_cron, :schedule_cron, :plan_limit, :now, :expected_result) do + '*/5 * * * *' | '59 14 * * *' | daily_limit_of_24_runs | Time.zone.local(2021, 5, 1, 15, 0) | Time.zone.local(2021, 5, 2, 15, 0) + '*/5 * * * *' | '*/1 * * * *' | daily_limit_of_24_runs | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 12, 0) + '*/5 * * * *' | '*/1 * * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 11, 10) + '*/5 * * * *' | '*/1 * * * *' | (1.day / 7.minutes).to_i | Time.zone.local(2021, 5, 27, 11, 0) | Time.zone.local(2021, 5, 27, 11, 10) + end + + with_them do + it 'calculates the next_run_at based on next available limit' do + travel_to(now) do + result = run_service + + expect(result).to eq(expected_result) + end + end + end + end + + context "when next_run_at is restricted by worker's availability" do + where(:worker_cron, :schedule_cron, :plan_limit, :now, :expected_result) do + '0 1 2 3 *' | '0 1 * * *' | daily_limit_of_144_runs | Time.zone.local(2021, 3, 2, 1, 0) | Time.zone.local(2022, 3, 2, 1, 0) + end + + with_them do + it 'calculates the next_run_at using worker_cron' do + travel_to(now) do + result = run_service + + expect(result).to eq(expected_result) + end + end + end + end + end +end +# rubocop:enable Layout/LineLength |