1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
# frozen_string_literal: true
namespace :knapsack do
desc "Run tests with knapsack runner"
task :rspec, [:rspec_args] do |_, args|
rspec_args = args[:rspec_args]&.split(' ') || []
unless QA::Runtime::Env.knapsack?
QA::Runtime::Logger.info("This environment is not compatible with parallel knapsack execution!")
QA::Runtime::Logger.info("Falling back to standard execution")
exit RSpec::Core::Runner.run([*rspec_args, "qa/specs/features"])
end
exit QA::Specs::KnapsackRunner.run(rspec_args)
end
desc "Download latest knapsack reports for parallel jobs"
task :download, [:stage_name] do |_, args|
test_stage_name = args[:stage_name]
knapsack_reports = ENV["QA_KNAPSACK_REPORTS"]&.split(",")
ci_token = ENV["QA_GITLAB_CI_TOKEN"]
QA::Support::KnapsackReport.configure!
reports = if knapsack_reports
knapsack_reports
else
unless ci_token
QA::Runtime::Logger.error("Missing QA_GITLAB_CI_TOKEN for automatically detecting parallel jobs")
next
end
QA::Support::ParallelPipelineJobs
.fetch(stage_name: test_stage_name, access_token: ci_token)
.map { |job| job.tr(":", "-") }
end
reports.each do |report_name|
QA::Support::KnapsackReport.new(report_name).download_report
rescue StandardError => e
QA::Runtime::Logger.error("Failed to download knapsack report '#{report_name}', error: #{e}")
end
end
desc "Create knapsack reports from existing reports for selective jobs"
task :create_reports_for_selective do
qa_tests = ENV["QA_TESTS"]
if qa_tests.blank?
next QA::Runtime::Logger.info("QA_TESTS not set, skipping report creation for selective execution")
end
reports = Dir.glob("knapsack/*").map { |file| file.match(%r{.*/(.*)?\.json})[1] }
reports.each do |report_name|
next unless report_name.include?('-selective-parallel')
QA::Support::KnapsackReport.new(report_name).create_for_selective(qa_tests)
rescue StandardError => e
QA::Runtime::Logger.error("Failed to create report '#{report_name}', error: #{e}")
end
end
desc "Merge and upload knapsack report"
task :upload, [:glob] do |_task, args|
QA::Support::KnapsackReport.configure!
QA::Support::KnapsackReport.upload_report(args[:glob])
end
desc "Report long running spec files"
task :notify_long_running_specs do
QA::Tools::LongRunningSpecReporter.execute
end
desc "Update fallback knapsack report"
task :update_fallback_report do
QA::Tools::KnapsackReportUpdater.run
end
end
|
