diff --git a/ai_test.go b/ai_test.go
index b40f6d6..e81d13e 100644
--- a/ai_test.go
+++ b/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"
diff --git a/config_test.go b/config_test.go
index 62527b5..e518b3a 100644
--- a/config_test.go
+++ b/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 {
diff --git a/driver_test.go b/driver_test.go
index 24f1a0c..8795990 100644
--- a/driver_test.go
+++ b/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()
 
diff --git a/main_test.go b/main_test.go
index 96df29e..14c1e49 100644
--- a/main_test.go
+++ b/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()
 
diff --git a/message_test.go b/message_test.go
index f5ea93f..dd7581b 100644
--- a/message_test.go
+++ b/message_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestParseSlackTestdata(t *testing.T) {
+	t.Parallel()
 	cases := map[string]struct {
 		inCh         string
 		slackMessage slackMessage
diff --git a/persistence.go b/persistence.go
index fc84f6b..d59b0e0 100644
--- a/persistence.go
+++ b/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
 	}
diff --git a/persistence_test.go b/persistence_test.go
index 85ec535..4899b15 100644
--- a/persistence_test.go
+++ b/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()
 
diff --git a/pipeline_test.go b/pipeline_test.go
index ae4601f..b2f9865 100644
--- a/pipeline_test.go
+++ b/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()
 
diff --git a/queue_test.go b/queue_test.go
index 8d20472..25c654b 100644
--- a/queue_test.go
+++ b/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()
 
diff --git a/slack.go b/slack.go
index 8579360..a4cd85e 100644
--- a/slack.go
+++ b/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
 	}
diff --git a/slack_test.go b/slack_test.go
index cb2b8c8..c4ea67a 100644
--- a/slack_test.go
+++ b/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()