Class: Dipa::AgentServices::CoordinatorStateService

Inherits:
BaseService show all
Defined in:
app/services/dipa/agent_services/coordinator_state_service.rb

Constant Summary collapse

AGENT_STATES_TO_CHECK_FOR = 
%i[
  timed_out
  processing_timed_out
  processing_failed
].freeze
COORDINATOR_STATES_TO_CHECK_FOR = 
%i[
  aborted_through_coordinator_timed_out
  aborted_through_coordinator_processing_timed_out
].freeze

Instance Method Summary collapse

Methods inherited from Dipa::ApplicationService

call

Instance Method Details

#call(agent:) ⇒ Object 



17
18
19
20
21
22
23
 
# File 'app/services/dipa/agent_services/coordinator_state_service.rb', line 17

def call(agent:)
  super

  return if _agent.reload.coordinator.finished_state?

  _handle_agent_states
end