Add built-in AssignTask command and AgentTaskAssigned event for AgenticAggregate

[Copilot]

Adds framework-level task assignment to agentic aggregates. An AssignTask command creates an Embabel AgentProcess and emits an AgentTaskAssigned event carrying the process ID and requesting party info.

api module — core types

• RequestingParty — sealed interface with AgentRequestingParty and HumanRequestingParty record permits. Jackson @JsonTypeInfo/@JsonSubTypes for polymorphic serde. Each variant carries a String role.
• HumanRequestingParty — carries only userId and role (no display name, for GDPR compliance)
• TaskAwareState — mirrors MemoryAwareState pattern: withAssignedTask() / withoutAssignedTask() immutable updates
• AssignedTask — record holding agentProcessId, taskDescription, requestingParty, taskMetadata, assignedAt

agentic module — command, event, handler

• AssignTaskCommand — first framework-owned Command. Fields: agenticAggregateId, taskDescription, requestingParty, taskMetadata
• AgentTaskAssignedEvent — includes agentProcessId from AgentProcess.getId(), linking Akces domain to Embabel runtime
• KafkaAgenticAggregateRuntime.builtInCommandHandler() — static factory method returning a CommandHandlerFunction that resolves the agent from the platform, creates an AgentProcess, and emits the event (follows the same single-dispatch pattern as the built-in event handlers)

Registration (follows existing memory event pattern)

• AgenticAggregateRuntime — ASSIGN_TASK_COMMAND_TYPE and AGENT_TASK_ASSIGNED_TYPE constants
• AgenticAggregateRuntimeFactory — wires builtInCommandHandler() + unified event-sourcing handler for all built-in events
• AkcesAgenticAggregateController — BUILTIN_COMMAND_TYPES list added; registerBuiltinSchemas() registers command schemas with forceRegisterOnIncompatible flag support (read from akces.aggregate.schemas.forceRegister environment property, matching AkcesAggregateController behaviour)
• KafkaAgenticAggregateRuntime — handleBuiltInEvent() unified static single-dispatch handler for MemoryStoredEvent, MemoryRevokedEvent, and AgentTaskAssignedEvent (renamed from handleMemoryEvent)

Usage sketch

// State implements TaskAwareState
record MyAgentState(String id, List<AssignedTask> assignedTasks, ...)
        implements AggregateState, TaskAwareState, MemoryAwareState { ... }

// Send from client
var cmd = new AssignTaskCommand("agg-1", "Analyze quarterly data",
        new HumanRequestingParty("user-42", "analyst"),
        Map.of("priority", "high"));
client.send("DEFAULT_TENANT", cmd);

// Framework handles: creates AgentProcess → emits AgentTaskAssignedEvent → updates state

Tests

• api: RequestingPartySerializationTest (sealed type, annotations, pattern matching), TaskAwareStateTest
• agentic: AssignTaskCommandHandlerTest (mocked AgentPlatform/AgentProcess via builtInCommandHandler), TaskEventSourcingTest, AssignTaskTypeConstantsTest

[Copilot]

Pull request overview

Adds framework-level task assignment for AgenticAggregate by introducing a built-in AssignTask command that creates an Embabel AgentProcess and emits an AgentTaskAssigned event, plus API-level types for tracking requesting party and assigned tasks in state.

Changes:

• Introduces RequestingParty (sealed) + AssignedTask + TaskAwareState in api with accompanying unit tests.
• Adds built-in AssignTaskCommand / AgentTaskAssignedEvent, registers their types/schemas, and wires built-in command + event-sourcing handlers in the agentic runtime.
• Adds agentic unit tests for type constants, command handler behavior, and task event-sourcing.

Reviewed changes

Copilot reviewed 18 out of 18 changed files in this pull request and generated 3 comments.

Show a summary per file

File	Description
plans/assign-task/assign-task-plan.md	Design/implementation plan for built-in task assignment support
main/api/src/main/java/org/elasticsoftware/akces/aggregate/RequestingParty.java	Sealed requesting-party abstraction with Jackson polymorphic annotations
main/api/src/main/java/org/elasticsoftware/akces/aggregate/AgentRequestingParty.java	Agent requesting-party record
main/api/src/main/java/org/elasticsoftware/akces/aggregate/HumanRequestingParty.java	Human requesting-party record
main/api/src/main/java/org/elasticsoftware/akces/aggregate/AssignedTask.java	Record to persist assigned task info in aggregate state
main/api/src/main/java/org/elasticsoftware/akces/aggregate/TaskAwareState.java	State contract for tracking assigned tasks
main/api/src/test/java/org/elasticsoftware/akces/aggregate/RequestingPartySerializationTest.java	Tests for sealed type shape + Jackson annotation presence
main/api/src/test/java/org/elasticsoftware/akces/aggregate/TaskAwareStateTest.java	Tests for TaskAwareState contract + AssignedTask usage
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/commands/AssignTaskCommand.java	Built-in command definition + schema metadata
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/events/AgentTaskAssignedEvent.java	Built-in event definition + schema metadata
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/AgenticAggregateRuntime.java	Registers built-in command/event type constants
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/runtime/AssignTaskCommandHandler.java	Built-in handler creating AgentProcess and emitting assignment event
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/runtime/KafkaAgenticAggregateRuntime.java	Built-in event-sourcing handler to update TaskAwareState
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/beans/AgenticAggregateRuntimeFactory.java	Wires built-in command handler + event-sourcing handler into runtime
main/agentic/src/main/java/org/elasticsoftware/akces/agentic/runtime/AkcesAgenticAggregateController.java	Registers built-in command schemas in addition to event schemas
main/agentic/src/test/java/org/elasticsoftware/akces/agentic/runtime/AssignTaskTypeConstantsTest.java	Verifies built-in type constants
main/agentic/src/test/java/org/elasticsoftware/akces/agentic/runtime/AssignTaskCommandHandlerTest.java	Verifies handler creates AgentProcess and emits correct event
main/agentic/src/test/java/org/elasticsoftware/akces/agentic/runtime/TaskEventSourcingTest.java	Verifies task event-sourcing handler updates TaskAwareState

[Copilot]

java.util.ArrayList is imported but never used in this file. This will fail compilation (unused import). Remove the import or use it if it was intended for new logic.

Suggested change

import java.util.ArrayList;

[Copilot]

The built-in AssignTask handler is registered using raw types and an unchecked cast (@SuppressWarnings({"unchecked", "rawtypes"}) and (AgenticAggregate) aggregate). This reduces type safety and can hide wiring errors at compile time. Prefer keeping the generic type parameter (e.g., AssignTaskCommandHandler<S> or AssignTaskCommandHandler<? extends AggregateState>) and avoid raw casts where possible.

Suggested change

	@SuppressWarnings({"unchecked", "rawtypes"})
	AssignTaskCommandHandler assignTaskHandler = new AssignTaskCommandHandler<>(
	(AgenticAggregate) aggregate, agentPlatform, agenticInfo.value());
	if (!(aggregate instanceof AgenticAggregate<?> agenticAggregate)) {
	throw new IllegalStateException("Agentic aggregate runtime requires an AgenticAggregate: "
	+ aggregate.getClass().getName());
	}
	@SuppressWarnings("unchecked")
	AgenticAggregate<S> typedAgenticAggregate = (AgenticAggregate<S>) agenticAggregate;
	AssignTaskCommandHandler<S> assignTaskHandler = new AssignTaskCommandHandler<>(
	typedAgenticAggregate, agentPlatform, agenticInfo.value());