Skip to content

feat(task): add new service task_manager#33

Merged
xaviave merged 1 commit into
mainfrom
feat/task_service
Mar 4, 2026
Merged

feat(task): add new service task_manager#33
xaviave merged 1 commit into
mainfrom
feat/task_service

Conversation

@xaviave
Copy link
Copy Markdown
Collaborator

@xaviave xaviave commented Feb 25, 2026

add new task service allowing tassk management via signal handling, heartbeat and logs.

@xaviave xaviave self-assigned this Feb 25, 2026
Copy link
Copy Markdown
Contributor

@GuillaumeSachet GuillaumeSachet left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Copy link
Copy Markdown

@Ekyoz Ekyoz Feb 25, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

(buf.validate.field).required = true,
Il faut indiquer que c'est obligatoire pour les champs necessaires pour les request/response.

Comment thread proto/agentic_mesh_protocol/task_manager/v1/task_manager_dto.proto Outdated
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

_messages au lieu de _message pour le nom du fichier

// - cancellation_reason: Reason for cancellation.
// - error_message: Human-readable error message.
// - exception_traceback: Full traceback if applicable.
message TaskError {
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ajouter la validation avec CEL pour chaque string
(buf.validate.field).required = true,
(buf.validate.field).string.min_len = 1

Comment thread proto/agentic_mesh_protocol/task_manager/v1/task_manager_dto.proto Outdated
Comment thread proto/agentic_mesh_protocol/task_manager/v1/task_manager_dto.proto Outdated
// Fields:
// - success: Whether the operation was successful.
// - tasks: Tasks with updated status after the stop.
message StopTasksResponse {
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

validation

(buf.validate.field).int32.gte = 0
];
// tasks is the list of tasks with their current status.
repeated Task tasks = 2;
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

validation

//
// Fields:
// - tasks: Tasks with their pending signal state.
message GetSignalsResponse {
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

validation

Copy link
Copy Markdown

@Ekyoz Ekyoz left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Il y a quelque validations manquantes et faut bien ajouter le required = true/false sur tous les champs.
A terme les responses vont changer avec les objets paginations et les bulks.

refactor(zod): split validation-mapper.ts into focused modules

Extract validation-mapper.ts (817 lines) into validation/ directory
with dedicated modules: types.ts (ValidationChain, MethodTarget),
cel-parser.ts (CEL expression → Zod translation), constraint-processors.ts
(unified buf.validate processors), and chain.ts (field extraction logic).
Eliminate field/item duplication via MethodTarget abstraction.

feat(task): simplify Task message and CreateTasksRequest

Remove mission_id from CreateTasksRequest, replace last_updated/error
fields with heartbeat_at in Task message, renumber fields accordingly.

feat(task): update amp

feat(task): update amp

feat(task): getisgnals as a bulk query
@xaviave xaviave force-pushed the feat/task_service branch from 409f905 to fa66148 Compare March 4, 2026 16:00
@xaviave xaviave merged commit 9614a5d into main Mar 4, 2026
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants