diff --git a/integration/concurrency_test.go b/integration/concurrency_test.go index 110301ab..f6bdb9d4 100644 --- a/integration/concurrency_test.go +++ b/integration/concurrency_test.go @@ -217,7 +217,7 @@ func TestMultiModelStress(t *testing.T) { defer wg.Done() for j := 0; j < 3; j++ { slog.Info("Starting", "req", i, "iter", j, "model", req[i].Model) - DoGenerate(ctx, t, client, req[i], resp[i], 90*time.Second, 5*time.Second) + DoGenerate(ctx, t, client, req[i], resp[i], 120*time.Second, 5*time.Second) } }(i) } diff --git a/integration/utils_test.go b/integration/utils_test.go index e133e76d..c6f19e98 100644 --- a/integration/utils_test.go +++ b/integration/utils_test.go @@ -85,7 +85,7 @@ func GetTestEndpoint() (*api.Client, string) { var serverMutex sync.Mutex var serverReady bool -func startServer(ctx context.Context, ollamaHost string) error { +func startServer(t *testing.T, ctx context.Context, ollamaHost string) error { // Make sure the server has been built CLIName, err := filepath.Abs("../ollama") if err != nil { @@ -200,7 +200,7 @@ func InitServerConnection(ctx context.Context, t *testing.T) (*api.Client, strin } lifecycle.ServerLogFile = fp.Name() fp.Close() - require.NoError(t, startServer(ctx, testEndpoint)) + require.NoError(t, startServer(t, ctx, testEndpoint)) } return client, testEndpoint, func() {