Class: Ci::Queue::PendingBuildsStrategy

Inherits:
Object
  • Object
show all
Defined in:
app/services/ci/queue/pending_builds_strategy.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(runner) ⇒ PendingBuildsStrategy

Returns a new instance of PendingBuildsStrategy.



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

def initialize(runner)
  @runner = runner
end

Instance Attribute Details

#runner ⇒ Object (readonly)

Returns the value of attribute runner.



6
7
8
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 6

def runner
  @runner
end

Instance Method Details

#build_ids(relation) ⇒ Object 



45
46
47
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 45

def build_ids(relation)
  relation.pluck(:build_id)
end

#builds_for_group_runner ⇒ Object 



19
20
21
22
23
24
25
26
27
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 19

def builds_for_group_runner
  return new_builds.none if runner.namespace_ids.empty?

  new_builds_relation = new_builds.where('ci_pending_builds.namespace_traversal_ids && ARRAY[?]::int[]', runner.namespace_ids)

  return order(new_builds_relation) if ::Feature.enabled?(:order_builds_for_group_runner)

  new_builds_relation
end

#builds_for_shared_runner ⇒ Object

rubocop:disable CodeReuse/ActiveRecord



13
14
15
16
17
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 13

def builds_for_shared_runner
  shared_builds = builds_available_for_shared_runners

  builds_ordered_for_shared_runners(shared_builds)
end

#builds_matching_tag_ids(relation, ids) ⇒ Object 



29
30
31
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 29

def builds_matching_tag_ids(relation, ids)
  relation.for_tags(runner.tags_ids)
end

#builds_with_any_tags(relation) ⇒ Object 



33
34
35
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 33

def builds_with_any_tags(relation)
  relation.where('cardinality(tag_ids) > 0')
end

#new_builds ⇒ Object 



41
42
43
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 41

def new_builds
  ::Ci::PendingBuild.all
end

#order(relation) ⇒ Object 



37
38
39
 
# File 'app/services/ci/queue/pending_builds_strategy.rb', line 37

def order(relation)
  relation.order('build_id ASC')
end