query job using job_id (#240)

ideacrew · Jul 9, 2024 · 5f466e2 · 5f466e2
1 parent 1ee7167
commit 5f466e2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/app/operations/fdsh/pvc/dmf/request/batch_process.rb b/app/operations/fdsh/pvc/dmf/request/batch_process.rb
@@ -1,6 +1,6 @@
 # frozen_string_literal: true
 
-# Fdsh::Pvc::Dmf::Request::BatchProcess.new.call({job_id: @job.id, transactions_per_file: 5000 })
+# Fdsh::Pvc::Dmf::Request::BatchProcess.new.call({job_id: job_id, transactions_per_file: 5000 })
 module Fdsh
   module Pvc
     module Dmf
@@ -50,7 +50,7 @@ def validate(params)
           # @param job_id [Integer] the ID of the job
           # @return [Dry::Monads::Result] the result of the find operation
           def find_job(job_id)
-            job = Transmittable::Job.find(job_id)
+            job = Transmittable::Job.where(job_id: job_id).last
             Failure("Job not found for job_id: #{job_id}") unless job
 
             Success(job)

diff --git a/spec/operations/fdsh/pvc/dmf/request/batch_process_spec.rb b/spec/operations/fdsh/pvc/dmf/request/batch_process_spec.rb
@@ -13,7 +13,7 @@
   before do
     Fdsh::Pvc::Dmf::Request::StoreRequest.new.call({ family_hash: family_hash, job_id: "dmf_request_1234" })
     @job = Transmittable::Job.where(key: :dmf_request).last
-    @result = described_class.new.call({ job_id: @job.id, transactions_per_file: 5000 })
+    @result = described_class.new.call({ job_id: "dmf_request_1234", transactions_per_file: 5000 })
   end
 
   context "process success" do