Module: Igniter::Extensions::Contracts::CollectionPack::LocalInvoker

Defined in:
lib/igniter/extensions/contracts/collection_pack.rb

Class Method Summary collapse

Class Method Details

.call(invocation:) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/igniter/extensions/contracts/collection_pack.rb', line 27

def call(invocation:)
  environment = Igniter::Contracts::Environment.new(profile: invocation.profile)
  session = Igniter::Extensions::Contracts::DataflowPack.session(
    environment,
    source: INTERNAL_SOURCE,
    key: invocation.key_name,
    context: invocation.inputs.keys,
    window: invocation.window,
    compiled_graph: invocation.compiled_graph
  )

  result = session.run(inputs: invocation.inputs.merge(INTERNAL_SOURCE => invocation.items))
  result.processed
end