t.Parallel pls

ai_test.go

@@ -14,18 +14,21 @@ import (
 )
 
 func TestAINoop(t *testing.T) {
+	t.Parallel()
 	ai := NewAINoop()
 
 	testAI(t, ai)
 }
 
 func TestAIOllama(t *testing.T) {
+	t.Parallel()
 	ai := NewAIOllama("http://localhost:11434", "gemma:2b")
 
 	testAI(t, ai)
 }
 
 func TestAILocal(t *testing.T) {
+	t.Parallel()
 	d := os.TempDir()
 	checkpoints := "checkpoints"
 	tokenizer := "tokenizer"

config_test.go

@@ -6,6 +6,7 @@ import (
 )
 
 func TestNewConfig(t *testing.T) {
+	t.Parallel()
 	if got, err := newConfigFromEnv(context.Background(), func(k string) string {
 		t.Logf("getenv(%s)", k)
 		switch k {

driver_test.go

@@ -7,10 +7,12 @@ import (
 )
 
 func TestNewTestDriver(t *testing.T) {
+	t.Parallel()
 	NewTestDriver(t)
 }
 
 func TestDriver(t *testing.T) {
+	t.Parallel()
 	ctx, can := context.WithTimeout(context.Background(), time.Second*15)
 	defer can()
 

main_test.go

@@ -19,6 +19,7 @@ import (
 )
 
 func TestRun(t *testing.T) {
+	t.Parallel()
 	ctx, can := context.WithTimeout(context.Background(), time.Second*10)
 	defer can()
 

message_test.go

@@ -7,6 +7,7 @@ import (
 )
 
 func TestParseSlackTestdata(t *testing.T) {
+	t.Parallel()
 	cases := map[string]struct {
 		inCh         string
 		slackMessage slackMessage

persistence.go

@@ -10,11 +10,11 @@ type MessageToPersistence struct {
 }
 
 func NewMessageToPersistencePipeline(ctx context.Context, cfg Config) (Pipeline, error) {
-	reader, err := NewQueue(ctx, "fromMessage", cfg.driver)
+	reader, err := NewQueue(ctx, "new_message", cfg.driver)
 	if err != nil {
 		return Pipeline{}, err
 	}
-	writer, err := NewQueue(ctx, "fromPersistence", cfg.driver)
+	writer, err := NewQueue(ctx, "new_persistence", cfg.driver)
 	if err != nil {
 		return Pipeline{}, err
 	}

persistence_test.go

@@ -7,6 +7,7 @@ import (
 )
 
 func TestMessageToPersistenceProcessor(t *testing.T) {
+	t.Parallel()
 	ctx, can := context.WithTimeout(context.Background(), time.Second*10)
 	defer can()
 

pipeline_test.go

@@ -7,6 +7,7 @@ import (
 )
 
 func TestPipeline(t *testing.T) {
+	t.Parallel()
 	ctx, can := context.WithTimeout(context.Background(), time.Second*10)
 	defer can()
 

queue_test.go

@@ -8,6 +8,7 @@ import (
 )
 
 func TestQueue(t *testing.T) {
+	t.Parallel()
 	ctx, can := context.WithTimeout(context.Background(), time.Second*10)
 	defer can()
 

slack.go

@@ -10,11 +10,11 @@ type SlackToMessage struct {
 }
 
 func NewSlackToMessagePipeline(ctx context.Context, cfg Config) (Pipeline, error) {
-	reader, err := NewQueue(ctx, "fromSlack", cfg.driver)
+	reader, err := NewQueue(ctx, "slack_event", cfg.driver)
 	if err != nil {
 		return Pipeline{}, err
 	}
-	writer, err := NewQueue(ctx, "fromMessage", cfg.driver)
+	writer, err := NewQueue(ctx, "new_message", cfg.driver)
 	if err != nil {
 		return Pipeline{}, err
 	}

slack_test.go

@@ -10,6 +10,7 @@ import (
 )
 
 func TestSlackToMessagePipeline(t *testing.T) {
+	t.Parallel()
 	ctx, can := context.WithTimeout(context.Background(), time.Second*5)
 	defer can()