Class: Kaisoku::Scheduler::ResultPersister

Inherits:
Object
  • Object
show all
Defined in:
lib/kaisoku/scheduler/result_persister.rb

Instance Method Summary collapse

Constructor Details

#initialize(test_map:) ⇒ ResultPersister

Returns a new instance of ResultPersister.



6
7
8
 
# File 'lib/kaisoku/scheduler/result_persister.rb', line 6

def initialize(test_map:)
  @test_map = test_map
end

Instance Method Details

#persist(results) ⇒ Object 



10
11
12
13
14
15
16
17
 
# File 'lib/kaisoku/scheduler/result_persister.rb', line 10

def persist(results)
  results.each_with_object({}) do |result, payloads|
    runtime_entity = runtime_entity(result)
    @test_map.upsert_entity(runtime_entity)
    persist_dependencies(runtime_entity, result)
    payloads[runtime_entity.id] = result.payload.merge(error: result.error).compact
  end
end