cleanup

hatchet-dev · Dec 17, 2024 · b180036 · b180036
1 parent ad903fe
commit b180036
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 7 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -2,7 +2,7 @@ version: "3.8"
 services:
   postgres:
     image: postgres:15.6
-    command: postgres -c 'max_connections=400'
+    command: postgres -c 'max_connections=200'
     restart: always
     environment:
       - POSTGRES_USER=hatchet

diff --git a/examples/bulk_imports/main.go b/examples/bulk_imports/main.go
@@ -83,7 +83,7 @@ func run() (func() error, error) {
 
 	var events []client.EventWithAdditionalMetadata
 
-	// 20000 times to test the bulk push
+	// 999 (max amount) times to test the bulk push
 
 	for i := 0; i < 999; i++ {
 		testEvent := userCreateEvent{

diff --git a/examples/loadtest/cli/main.go b/examples/loadtest/cli/main.go
@@ -1,10 +1,7 @@
 package main
 
 import (
-	"fmt"
 	"log"
-	"math/rand"
-	"os"
 	"time"
 
 	"github.com/joho/godotenv"
@@ -25,7 +22,6 @@ func main() {
 	var delay time.Duration
 	var workerDelay time.Duration
 	var logLevel string
-	os.Setenv("HATCHET_CLIENT_NAMESPACE", fmt.Sprintf("loadtest-ns-%d", rand.Intn(100000))) //nolint
 	var loadtest = &cobra.Command{
 		Use: "loadtest",
 		Run: func(cmd *cobra.Command, args []string) {

diff --git a/internal/services/controllers/workflows/controller.go b/internal/services/controllers/workflows/controller.go
@@ -317,7 +317,7 @@ func (wc *WorkflowsControllerImpl) handleTask(ctx context.Context, task *msgqueu
 	case "replay-workflow-run":
 		return wc.handleReplayWorkflowRun(ctx, task)
 	case "workflow-run-queued":
-		// we only do this now for certain workflows
+		// we only do this now for workflows that cannot be short circuited
 		return wc.handleWorkflowRunQueued(ctx, task)
 
 	case "get-group-key-run-started":