collect errors

Signed-off-by: mudler <mudler@localai.io>

core/agent/agent.go

@@ -990,6 +990,7 @@ func (a *Agent) periodicallyRun(timer *time.Timer) {
 }
 
 func (a *Agent) Run() error {
+
 	a.startNewConversationsConsumer()
 	xlog.Debug("Agent is now running", "agent", a.Character.Name)
 	// The agent run does two things:
@@ -1012,12 +1013,7 @@ func (a *Agent) Run() error {
 	var muErr sync.Mutex
 	var wg sync.WaitGroup
 
-	parallelJobs := a.options.parallelJobs
-	if a.options.parallelJobs == 0 {
-		parallelJobs = 1
-	}
-
-	for i := 0; i < parallelJobs; i++ {
+	for i := 0; i <= a.options.parallelJobs; i++ {
 		xlog.Debug("Starting agent worker", "worker", i)
 		wg.Add(1)
 		go func() {

core/agent/options.go

@@ -64,7 +64,6 @@ func (o *options) SeparatedMultimodalModel() bool {
 
 func defaultOptions() *options {
 	return &options{
-		parallelJobs: 1,
 		periodicRuns: 15 * time.Minute,
 		LLMAPI: llmOptions{
 			APIURL: "http://localhost:8080",

core/agent/state_test.go

@@ -25,7 +25,6 @@ var _ = Describe("Agent test", func() {
 			agent, err = New(
 				WithLLMAPIURL(apiURL),
 				WithModel(testModel),
-				WithTimeout("10m"),
 				WithRandomIdentity(),
 			)
 			Expect(err).ToNot(HaveOccurred())