Class: EdiPriceFlowWorker

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Job, Workers::EdiFlowDispatch
Defined in:
app/workers/edi_price_flow_worker.rb

Overview

Sidekiq worker: edi price flow.

Dispatcher only — it fans the flow out to one EdiOrchestratorFlowWorker per
orchestrator class and lets a Sidekiq Pro batch report the outcome. See
Workers::EdiFlowDispatch for why the unit is a vendor rather than a partner,
and EdiInventoryFlowWorker for what +lock_ttl+ is guarding against.

Instance Method Summary collapse

Methods included from Workers::EdiFlowDispatch

#dispatch_flow

Instance Method Details

#perform(options = {}) ⇒ String, Array

Returns batch id when fanned out, results when targeted.

Parameters:

  • options (Hash) (defaults to: {})

    optional orchestrator_name / partner filters

Options Hash (options):

  • orchestrator_name (String)

    restrict the flow to one orchestrator class

  • partner (String)

    restrict the flow to one partner

Returns:

  • (String, Array)

    batch id when fanned out, results when targeted



21
22
23
# File 'app/workers/edi_price_flow_worker.rb', line 21

def perform(options = {})
  dispatch_flow(:execute_price_flow, options)
end