Add AgentTaskFinishedEvent emitted when AgentProcess completes

[Copilot]

Agent tasks need lifecycle completion tracking. After each tick in the idle-poll cycle, the runtime now checks AgentProcess.getFinished() and emits an AgentTaskFinishedEvent carrying the AgentProcessStatusCode (COMPLETED, FAILED, TERMINATED, KILLED, STUCK). A built-in event-sourcing handler clears the task from TaskAwareState.

Changes

• New AgentTaskFinishedEvent — record with agentProcessId, AgentProcessStatusCode status, finishedAt
• AgenticAggregateRuntime — add AGENT_TASK_FINISHED_TYPE constant
• KafkaAgenticAggregateRuntime
  • onAgentTaskFinished() handler calls TaskAwareState.withoutAssignedTask()
  • handleBuiltInEvent() dispatch updated for new event type
  • resumeNextAgentTask() checks agentProcess.getFinished() post-tick, appends finished event to stream
• AgenticAggregateRuntimeFactory — registers AGENT_TASK_FINISHED_TYPE with built-in event-sourcing handler

Tick + finish detection in resumeNextAgentTask

Stream<DomainEvent> tickEvents =
        AgentProcessSingleTickRunner.tick(agentProcess, delegate.getAllDomainEventTypes());

if (agentProcess.getFinished()) {
    AgentTaskFinishedEvent finishedEvent = new AgentTaskFinishedEvent(
            state.getAggregateId(),
            task.agentProcessId(),
            agentProcess.getStatus(),
            Instant.now());
    tickEvents = Stream.concat(tickEvents, Stream.of(finishedEvent));
}

delegate.processDomainEvents(tickEvents, task.agentProcessId(), ...);

[Copilot]

Pull request overview

Adds agent-task lifecycle completion tracking to the agentic runtime by emitting a new built-in AgentTaskFinishedEvent when an AgentProcess finishes, and applying a built-in event-sourcing handler to remove the corresponding AssignedTask from TaskAwareState.

Changes:

• Introduces AgentTaskFinishedEvent (includes process status + finish timestamp).
• Updates KafkaAgenticAggregateRuntime to emit the finished event after a tick when AgentProcess.getFinished() is true, and to handle the event via built-in dispatch.
• Registers the new domain event type + built-in event-sourcing handler in AgenticAggregateRuntimeFactory, and adds/updates unit tests around handler dispatch + resume behavior.

Reviewed changes

Copilot reviewed 7 out of 7 changed files in this pull request and generated no comments.

Show a summary per file

File	Description
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/events/AgentTaskFinishedEvent.java	Adds new built-in domain event for agent task completion.
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/AgenticAggregateRuntime.java	Adds AGENT_TASK_FINISHED_TYPE constant for runtime registration.
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/runtime/KafkaAgenticAggregateRuntime.java	Emits finished events post-tick and applies them via built-in event-sourcing handler.
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/beans/AgenticAggregateRuntimeFactory.java	Registers finished event type and handler with the runtime builder.
main/agentic/src/test/java/org/elasticsoftware/akces/agentic/runtime/TaskEventSourcingTest.java	Adds tests for applying/dispatching AgentTaskFinishedEvent and assign→finish reconstruction.
main/agentic/src/test/java/org/elasticsoftware/akces/agentic/runtime/ResumeNextAgentTaskTest.java	Adds tests ensuring resumeNextAgentTask emits (or doesn’t emit) AgentTaskFinishedEvent.
main/agentic/src/test/java/org/elasticsoftware/akces/agentic/runtime/AssignTaskTypeConstantsTest.java	Verifies the new AGENT_TASK_FINISHED_TYPE constant configuration.