Fix tests

ylem-co · Sep 6, 2024 · eedc626 · eedc626
1 parent 7e015f7
commit eedc626
Show file tree

Hide file tree

Showing 16 changed files with 17 additions and 15 deletions.
diff --git a/backend/pipelines/go.mod b/backend/pipelines/go.mod
@@ -41,7 +41,7 @@ require (
 	github.com/russross/blackfriday/v2 v2.0.1 // indirect
 	github.com/shurcooL/sanitized_anchor_name v1.0.0 // indirect
 	github.com/syndtr/goleveldb v1.0.0 // indirect
-	github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4 // indirect
+	github.com/ylem-co/shared-messaging v0.0.0-20240906192118-7b8fffc71211 // indirect
 	go.uber.org/atomic v1.6.0 // indirect
 	golang.org/x/crypto v0.0.0-20210921155107-089bfa567519 // indirect
 	golang.org/x/net v0.0.0-20211029224645-99673261e6eb // indirect

diff --git a/backend/pipelines/go.sum b/backend/pipelines/go.sum
@@ -969,6 +969,8 @@ github.com/ylem-co/shared-messaging v0.0.0-20240717175742-c78b09b209c0 h1:MxPzTV
 github.com/ylem-co/shared-messaging v0.0.0-20240717175742-c78b09b209c0/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
 github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4 h1:EMlJO+cJp5mC+bNGeq/leKaRNPXMnN/LESGKTIpr+FQ=
 github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4/go.mod h1:OAQr4N1aBobOY7KC4D4bRXWmdMl4SHxsKSs8yBniIoM=
+github.com/ylem-co/shared-messaging v0.0.0-20240906192118-7b8fffc71211 h1:80cVDw/cJjxYz3DbnjrfXoKTwJD9Rahfzncsk0tQJgw=
+github.com/ylem-co/shared-messaging v0.0.0-20240906192118-7b8fffc71211/go.mod h1:OAQr4N1aBobOY7KC4D4bRXWmdMl4SHxsKSs8yBniIoM=
 github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

diff --git a/backend/pipelines/tests/services/messaging/aggregator_test.go b/backend/pipelines/tests/services/messaging/aggregator_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/api_test.go b/backend/pipelines/tests/services/messaging/api_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/code_test.go b/backend/pipelines/tests/services/messaging/code_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/condition_test.go b/backend/pipelines/tests/services/messaging/condition_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/external_trigger_test.go b/backend/pipelines/tests/services/messaging/external_trigger_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/filter_test.go b/backend/pipelines/tests/services/messaging/filter_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/for_each_test.go b/backend/pipelines/tests/services/messaging/for_each_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/gpt_test.go b/backend/pipelines/tests/services/messaging/gpt_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/merge_test.go b/backend/pipelines/tests/services/messaging/merge_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 func TestMergeTaskMessageFactory_CreateMessage(t *testing.T) {

diff --git a/backend/pipelines/tests/services/messaging/notification_test.go b/backend/pipelines/tests/services/messaging/notification_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 func TestNotificationTaskMessageFactory_CreateMessage(t *testing.T) {

diff --git a/backend/pipelines/tests/services/messaging/processor_test.go b/backend/pipelines/tests/services/messaging/processor_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/query_test.go b/backend/pipelines/tests/services/messaging/query_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 func TestQueryTaskMessageFactory_CreateMessage(t *testing.T) {

diff --git a/backend/pipelines/tests/services/messaging/run_pipeline_test.go b/backend/pipelines/tests/services/messaging/run_pipeline_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/tests/services/messaging/transformer_test.go b/backend/pipelines/tests/services/messaging/transformer_test.go
@@ -6,7 +6,7 @@ import (
 	"ylem_pipelines/app/task"
 	ylem_messaging "ylem_pipelines/services/messaging"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )