Class: Ci::Queue::BuildQueueService

Inherits:
Object
  • Object
show all
Includes:
Gitlab::Utils::StrongMemoize
Defined in:
app/services/ci/queue/build_queue_service.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(runner) ⇒ BuildQueueService

Returns a new instance of BuildQueueService.



10
11
12
 
# File 'app/services/ci/queue/build_queue_service.rb', line 10

def initialize(runner)
  @runner = runner
end

Instance Attribute Details

#runner ⇒ Object (readonly)

Returns the value of attribute runner.



8
9
10
 
# File 'app/services/ci/queue/build_queue_service.rb', line 8

def runner
  @runner
end

Instance Method Details

#build_candidates ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'app/services/ci/queue/build_queue_service.rb', line 18

def build_candidates
  candidates =
    if runner.project_type?
      builds_for_project_runner
    elsif runner.group_type?
      builds_for_group_runner
    else
      builds_for_shared_runner
    end

  candidates = builds_for_protected_runner(candidates) if runner.ref_protected?

  # pick builds that does not have other tags than runner's one
  candidates = builds_matching_tag_ids(candidates, runner.tagging_tag_ids)

  # pick builds that have at least one tag
  candidates = builds_with_any_tags(candidates) unless runner.run_untagged?

  candidates
end

#builds_for_group_runner ⇒ Object

rubocop:disable CodeReuse/ActiveRecord



47
48
49
 
# File 'app/services/ci/queue/build_queue_service.rb', line 47

def builds_for_group_runner
  strategy.builds_for_group_runner
end

#builds_for_project_runner ⇒ Object 



51
52
53
54
55
56
 
# File 'app/services/ci/queue/build_queue_service.rb', line 51

def builds_for_project_runner
  relation = new_builds
    .where(project: runner_projects_relation)

  order(relation)
end

#builds_for_protected_runner(relation) ⇒ Object 



58
59
60
 
# File 'app/services/ci/queue/build_queue_service.rb', line 58

def builds_for_protected_runner(relation)
  relation.ref_protected
end

#builds_for_shared_runner ⇒ Object

This is overridden in EE



42
43
44
 
# File 'app/services/ci/queue/build_queue_service.rb', line 42

def builds_for_shared_runner
  strategy.builds_for_shared_runner
end

#builds_matching_tag_ids(relation, ids) ⇒ Object 



62
63
64
 
# File 'app/services/ci/queue/build_queue_service.rb', line 62

def builds_matching_tag_ids(relation, ids)
  strategy.builds_matching_tag_ids(relation, ids)
end

#builds_with_any_tags(relation) ⇒ Object 



66
67
68
 
# File 'app/services/ci/queue/build_queue_service.rb', line 66

def builds_with_any_tags(relation)
  strategy.builds_with_any_tags(relation)
end

#execute(relation) ⇒ Object 



74
75
76
 
# File 'app/services/ci/queue/build_queue_service.rb', line 74

def execute(relation)
  strategy.build_and_partition_ids(relation)
end

#new_builds ⇒ Object 



14
15
16
 
# File 'app/services/ci/queue/build_queue_service.rb', line 14

def new_builds
  strategy.new_builds
end

#order(relation) ⇒ Object 



70
71
72
 
# File 'app/services/ci/queue/build_queue_service.rb', line 70

def order(relation)
  strategy.order(relation)
end