Class: Wurk::Batch::DeathHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/wurk/batch/death_handler.rb

Overview

Registered as a config death_handler. Fires for every job that exhausts retries or carries dead: false and discards. If the job carries a bid, we BATCH_ACK_COMPLETE → record the death → fire :death callback exactly once per batch (first death only).

Spec: docs/target/sidekiq-pro.md §2.4 (:death).

Class Method Summary collapse

Class Method Details

.call(job, _exception) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/wurk/batch/death_handler.rb', line 15

def self.call(job, _exception)
  bid = job['bid']
  return unless bid

  result = Wurk.redis do |conn|
    Wurk::Lua::Loader.eval_cached(
      conn,
      :batch_ack_complete,
      keys: ["b-#{bid}", "b-#{bid}-jids", "b-#{bid}-died", "b-#{bid}-failed"],
      argv: [job['jid']]
    )
  end
  live, _died, first_death = Array(result).map(&:to_i)

  restamp_ttls(bid)

  Wurk::Batch::Callbacks.fire_death(bid) if first_death == 1
  return unless live.zero?

  # Through the gated maybe_fire, not a direct fire_complete: this batch
  # may still have running child batches, and spec §2.4 ordering says
  # its `:complete` must wait for theirs (#209). `:success` stays
  # suppressed regardless — the death above set the durable death flag.
  Wurk::Batch::Callbacks.maybe_fire(bid, pending: Wurk::Batch::Callbacks.pending_for(bid), live: 0)
end

.restamp_ttls(bid) ⇒ Object

A stale job can die AFTER its batch keys expired; the ack writes recreate them with no TTL — permanent key leakage. EXPIRE NX stamps only keys that lost their TTL, leaving live batches' clocks alone.



44
45
46
47
48
49
50
 
# File 'lib/wurk/batch/death_handler.rb', line 44

def self.restamp_ttls(bid)
  Wurk.redis do |conn|
    conn.pipelined do |pipe|
      Batch.keys_for(bid).each { |key| pipe.call('EXPIRE', key, Batch::DEFAULT_EXPIRY_SECONDS, 'NX') }
    end
  end
end