@@ -206,7 +206,7 @@ def self.call(task, ctx, exec_context:, use_application_ctx___: true, **)
206206
207207 it "circuit_options, depth-only" do
208208 def capture_task ( id :)
209- -> ( ctx , tmp , exec_context :, lib_exec_context : nil , **) { ctx [ :captured ] << [ id , exec_context , lib_exec_context ] . compact ; return ctx , nil , tmp }
209+ -> ( ctx , exec_context :, lib_exec_context : nil , **) { ctx [ :captured ] << [ id , exec_context , lib_exec_context ] . compact ; return ctx , nil }
210210 end
211211
212212 model_pipe = pipeline_circuit (
@@ -232,7 +232,7 @@ def capture_task(id:)
232232 )
233233
234234 # As we pass in exec_context: as a kwarg, it's passed to all siblings etc.
235- ctx , signal = Circuit ::Processor . ( create_pipe , { captured : [ ] } , { } , exec_context : "Object" )
235+ ctx , signal = Circuit ::Processor . ( create_pipe , { captured : [ ] , exec_context : "Object" } )
236236 assert_equal ctx [ :captured ] , [ [ 1 , "Object" ] , [ 2 , "Object" ] , [ 3 , "Object" ] , [ 4 , "Object" , "Validate::Input" ] , [ 5 , "Object" , "Validate::Input" ] , [ 6 , "Object" ] ]
237237
238238# FIXME: new test case.
@@ -242,7 +242,7 @@ def capture_task(id:)
242242 [ :Validate , validate_pipe , Circuit ::Processor ] ,
243243 )
244244
245- ctx , signal = Circuit ::Processor . ( create_pipe , { captured : [ ] } , { } , exec_context : "Object" )
245+ ctx , signal = Circuit ::Processor . ( create_pipe , { captured : [ ] , exec_context : "Object" } )
246246 assert_equal ctx [ :captured ] , [ [ 1 , "Model" ] , [ 2 , "Model" ] , [ 3 , "Model" ] , [ 4 , "Object" , "Validate::Input" ] , [ 5 , "Object" , "Validate::Input" ] , [ 6 , "Object" ] ]
247247
248248 end
0 commit comments