Class: Fractor::Workflow::ExecutionHooks

Inherits:

Object

• Object
• Fractor::Workflow::ExecutionHooks

Defined in:

lib/fractor/workflow/execution_hooks.rb

Overview

Manages lifecycle hooks for workflow execution. Allows registering callbacks for workflow/job lifecycle events.

Instance Method Summary

• #initialize ⇒ ExecutionHooks constructor

  A new instance of ExecutionHooks.

• #register(event) {|Object| ... } ⇒ Object

  Register a callback for a specific event.

• #trigger(event, *args) ⇒ Object

  Trigger all callbacks registered for an event.

Constructor Details

#initialize ⇒ ExecutionHooks

Returns a new instance of ExecutionHooks.

# File 'lib/fractor/workflow/execution_hooks.rb', line 8

def initialize
  @hooks = Hash.new { |h, k| h[k] = [] }
end

Instance Method Details

#register(event) {|Object| ... } ⇒ Object

Register a callback for a specific event.

Examples:

Register a workflow start hook

hooks.register(:workflow_start) do |workflow|
  puts "Workflow starting: #{workflow.class.workflow_name}"
end

Parameters:

• event (Symbol) —

  The event to hook into

Yields:

• (Object) —

  Block to execute when event is triggered

# File 'lib/fractor/workflow/execution_hooks.rb', line 21

def register(event, &block)
  @hooks[event] << block
end

#trigger(event, *args) ⇒ Object

Trigger all callbacks registered for an event.

Examples:

Trigger workflow completion

hooks.trigger(:workflow_complete, result)

Parameters:

• event (Symbol) —

  The event to trigger

• args (Array) —

  Arguments to pass to the callbacks

# File 'lib/fractor/workflow/execution_hooks.rb', line 32

def trigger(event, *args)
  @hooks[event].each do |hook|
    hook.call(*args)
  end
end