Fix a couple small bugs

fractaledmind · Dec 23, 2024 · 56c9106 · 56c9106
1 parent 217faa8
commit 56c9106
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/acidic_job/workflow.rb b/lib/acidic_job/workflow.rb
@@ -10,7 +10,7 @@ module Workflow
 
     attr_reader :execution, :ctx
 
-    def execute_workflow(unique_by:, with: [], &block)
+    def execute_workflow(unique_by:, with: [Plugins::TransactionalStep], &block)
       @plugins = with
       serialized_job = serialize
 
@@ -172,8 +172,9 @@ def perform_step_for(step_definition)
 
       raise InvalidMethodError.new(step_name) unless step_method.arity.zero?
 
-      plugin_pipeline_callable = plugins.reverse.reduce(step_method) do |callable, plugin|
-        proc { plugin.wrap(step_definition) { callable.call } }
+      step_kwargs = step_definition.symbolize_keys
+      plugin_pipeline_callable = @plugins.reverse.reduce(step_method) do |callable, plugin|
+        proc { plugin.wrap(**step_kwargs) { callable.call } }
       end
 
       catch(:repeat) { plugin_pipeline_callable.call }