Remove legacy query to find migrated job artifacts

This commit removes the legacy queries to find migrated
job artifacts since we made Foreign Data Wrapper (FDW)
a hard requirement for Geo on GitLab 12.0.

ee/app/finders/geo/job_artifact_registry_finder.rb

@@ -61,14 +61,12 @@ module Geo
 
     # rubocop: disable CodeReuse/ActiveRecord
     def find_migrated_local(batch_size:, except_artifact_ids: [])
-      relation =
-        if use_legacy_queries_for_selective_sync?
-          legacy_finder.job_artifacts_migrated_local(except_artifact_ids: except_artifact_ids)
-        else
-          job_artifacts_migrated_local(except_artifact_ids: except_artifact_ids)
-        end
-
-      relation.limit(batch_size)
+      fdw_geo_node
+        .job_artifacts
+        .inner_join_job_artifact_registry
+        .with_files_stored_remotely
+        .id_not_in(except_artifact_ids)
+        .limit(batch_size)
     end
     # rubocop: enable CodeReuse/ActiveRecord
 
@@ -111,13 +109,5 @@ module Geo
         .inner_join_job_artifact_registry
         .syncable
     end
-
-    def job_artifacts_migrated_local(except_artifact_ids:)
-      fdw_geo_node
-        .job_artifacts
-        .inner_join_job_artifact_registry
-        .with_files_stored_remotely
-        .id_not_in(except_artifact_ids)
-    end
   end
 end

ee/app/finders/geo/legacy_job_artifact_registry_finder.rb

@@ -5,15 +5,5 @@ module Geo
     def syncable
       current_node.job_artifacts.syncable
     end
-
-    def job_artifacts_migrated_local(except_artifact_ids: [])
-      registry_artifact_ids = Geo::JobArtifactRegistry.pluck_artifact_key - except_artifact_ids
-
-      legacy_inner_join_registry_ids(
-        current_node.job_artifacts.with_files_stored_remotely,
-        registry_artifact_ids,
-        Ci::JobArtifact
-      )
-    end
   end
 end

ee/spec/finders/geo/job_artifact_registry_finder_spec.rb

@@ -715,69 +715,5 @@ describe Geo::JobArtifactRegistryFinder, :geo do
         end
       end
     end
-
-    describe '#find_migrated_local' do
-      let!(:job_artifact_1) { create(:ci_job_artifact, project: synced_project) }
-      let!(:job_artifact_remote_1) { create(:ci_job_artifact, :remote_store, project: synced_project) }
-      let!(:job_artifact_remote_2) { create(:ci_job_artifact, :remote_store, project: unsynced_project) }
-      let!(:job_artifact_remote_3) { create(:ci_job_artifact, :remote_store, project: project_broken_storage, expire_at: Date.yesterday) }
-
-      it 'returns job artifacts remotely and successfully synced locally' do
-        create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_1.id)
-        create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_2.id)
-
-        job_artifacts = subject.find_migrated_local(batch_size: 10, except_artifact_ids: [job_artifact_remote_1.id])
-
-        expect(job_artifacts).to match_ids(job_artifact_remote_2)
-      end
-
-      it 'excludes synced job artifacts that are stored locally' do
-        create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_1.id)
-        create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_2.id)
-        create(:geo_job_artifact_registry, artifact_id: job_artifact_1.id)
-
-        job_artifacts = subject.find_migrated_local(batch_size: 10)
-
-        expect(job_artifacts).to match_ids(job_artifact_remote_1, job_artifact_remote_2)
-      end
-
-      it 'includes synced job artifacts that are expired' do
-        create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_3.id)
-
-        job_artifacts = subject.find_migrated_local(batch_size: 10)
-
-        expect(job_artifacts).to match_ids(job_artifact_remote_3)
-      end
-
-      context 'with selective sync by namespace' do
-        before do
-          secondary.update!(selective_sync_type: 'namespaces', namespaces: [synced_group])
-        end
-
-        it 'returns job artifacts remotely and successfully synced locally' do
-          create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_1.id)
-          create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_2.id)
-
-          job_artifacts = subject.find_migrated_local(batch_size: 10)
-
-          expect(job_artifacts).to match_ids(job_artifact_remote_1)
-        end
-      end
-
-      context 'with selective sync by shard' do
-        before do
-          secondary.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
-        end
-
-        it 'returns job artifacts remotely and successfully synced locally' do
-          create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_1.id)
-          create(:geo_job_artifact_registry, artifact_id: job_artifact_remote_3.id)
-
-          job_artifacts = subject.find_migrated_local(batch_size: 10)
-
-          expect(job_artifacts).to match_ids(job_artifact_remote_3)
-        end
-      end
-    end
   end
 end