summaryrefslogtreecommitdiff
path: root/internal/executor/channel.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/executor/channel.go')
-rw-r--r--internal/executor/channel.go22
1 files changed, 11 insertions, 11 deletions
diff --git a/internal/executor/channel.go b/internal/executor/channel.go
index e815b00..6353a40 100644
--- a/internal/executor/channel.go
+++ b/internal/executor/channel.go
@@ -8,13 +8,13 @@ import (
"sync"
"time"
+ "github.com/google/uuid"
"github.com/thepeterstone/claudomator/internal/agentchannel"
"github.com/thepeterstone/claudomator/internal/event"
"github.com/thepeterstone/claudomator/internal/role"
"github.com/thepeterstone/claudomator/internal/storage"
"github.com/thepeterstone/claudomator/internal/story"
"github.com/thepeterstone/claudomator/internal/task"
- "github.com/google/uuid"
)
// AgentChannel, SubtaskSpec, BlockedError, and ErrAgentBlocked used to be
@@ -152,15 +152,15 @@ func (c *storeChannel) SpawnSubtask(_ context.Context, spec SubtaskSpec) (string
}
child := &task.Task{
ID: uuid.NewString(),
- Name: spec.Name,
- ParentTaskID: c.taskID,
- Agent: agent,
- Priority: task.PriorityNormal,
- DependsOn: spec.DependsOn,
- AcceptanceCriteria: spec.AcceptanceCriteria,
- State: task.StatePending,
- CreatedAt: now,
- UpdatedAt: now,
+ Name: spec.Name,
+ ParentTaskID: c.taskID,
+ Agent: agent,
+ Priority: task.PriorityNormal,
+ DependsOn: spec.DependsOn,
+ AcceptanceCriteria: spec.AcceptanceCriteria,
+ State: task.StatePending,
+ CreatedAt: now,
+ UpdatedAt: now,
}
if err := c.store.CreateTask(child); err != nil {
return "", err
@@ -287,4 +287,4 @@ func (c *storeChannel) ReportVerdict(_ context.Context, approved bool, reasoning
Actor: event.ActorAgent,
Payload: payload,
})
-} \ No newline at end of file
+}