Update RegisterJobService to use partition_id
In Ci::RegisterJobService
we read from ci_pending_builds
and use the ids to fetch the jobs from p_ci_builds
:
build_ids = retrieve_queue(-> { queue.execute(builds) })
build_ids.each { |build_id| yield Ci::Build.find(build_id) }
This query doesn't use the partition_id
to read from p_ci_builds
.
Proposal
Modify the queuing strategy to return (id, partition_id)
tuple and use it to fetch the data from p_ci_builds
.