Function logOutputs

internal/controller/executor/executor.go:197–205

(ctx context.Context, el EventLog, execID string, start *proto.AgentStart, outputs []*proto.Message)

}

func logOutputs(ctx context.Context, el EventLog, execID string, start *proto.AgentStart, outputs []*proto.Message) error {
	return el.AppendExec(ctx, &proto.ExecutionEvent{
		Timestamp: timestamppb.Now(),
		ExecId:    execID,
		AgentId:   start.AgentId,
		Outputs:   outputs,
		State:     proto.State_STATE_PENDING,
	})
}