Add ability to find a currently running work by jid

Changes.md

@@ -2,6 +2,11 @@
 
 [Sidekiq Changes](https://github.com/sidekiq/sidekiq/blob/main/Changes.md) | [Sidekiq Pro Changes](https://github.com/sidekiq/sidekiq/blob/main/Pro-Changes.md) | [Sidekiq Enterprise Changes](https://github.com/sidekiq/sidekiq/blob/main/Ent-Changes.md)
 
+HEAD
+----------
+
+- Add ability to find a currently running work by jid [#6212, fatkodima]
+
 7.2.2
 ----------
 

lib/sidekiq/api.rb

@@ -1136,6 +1136,20 @@ def size
         end
       end
     end
+
+    ##
+    # Find the work which represents a job with the given JID.
+    # *This is a slow O(n) operation*.  Do not use for app logic.
+    #
+    # @param jid [String] the job identifier
+    # @return [Sidekiq::Work] the work or nil
+    def find_work_by_jid(jid)
+      each do |_process_id, _thread_id, work|
+        job = work.job
+        return work if job.jid == jid
+      end
+      nil
+    end
   end
 
   # Sidekiq::Work represents a job which is currently executing.

test/api_test.rb

@@ -661,6 +661,27 @@ class JobWithTags
       assert_equal ["5678", "1234"], w.map { |_, tid, _| tid }
     end
 
+    it "can find a work by jid" do
+      w = Sidekiq::Workers.new
+      hn = Socket.gethostname
+      key = "#{hn}:#{$$}"
+      @cfg.redis do |conn|
+        conn.sadd("processes", [key])
+      end
+
+      s = "#{key}:work"
+      jid = "abcdef"
+      data = Sidekiq.dump_json({"payload" => {"args" => ["foo"], "jid" => jid}, "queue" => "default", "run_at" => Time.now.to_i})
+      @cfg.redis do |c|
+        c.hset(s, "1234", data)
+      end
+
+      assert_nil w.find_work_by_jid("nonexistent")
+
+      work = w.find_work_by_jid(jid)
+      assert_equal ["foo"], work.job.args
+    end
+
     it "can reschedule jobs" do
       add_retry("foo1")
       add_retry("foo2")