back to localhost now that temporal no longer a container

PeerDB-io · Feb 29, 2024 · 1085999 · 1085999
1 parent d371f98
commit 1085999
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/flow/e2e/main.go b/flow/e2e/main.go
@@ -16,7 +16,7 @@ func TestMain(m *testing.M) {
 	group, _ := errgroup.WithContext(context.Background())
 	group.Go(func() error {
 		return cmd.WorkerMain(end, &cmd.WorkerOptions{
-			TemporalHostPort:  "temporal:7233",
+			TemporalHostPort:  "localhost:7233",
 			EnableProfiling:   false,
 			PyroscopeServer:   "",
 			TemporalNamespace: "default",
@@ -26,7 +26,7 @@ func TestMain(m *testing.M) {
 	})
 	group.Go(func() error {
 		return cmd.SnapshotWorkerMain(end, &cmd.SnapshotWorkerOptions{
-			TemporalHostPort:  "temporal:7233",
+			TemporalHostPort:  "localhost:7233",
 			TemporalNamespace: "default",
 			TemporalCert:      "",
 			TemporalKey:       "",

diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
@@ -163,10 +163,7 @@ func SetupCDCFlowStatusQuery(t *testing.T, env WorkflowRun, connectionGen FlowCo
 	for {
 		time.Sleep(time.Second)
 		counter++
-		response, err := env.Query(
-			shared.CDCFlowStateQuery,
-			connectionGen.FlowJobName,
-		)
+		response, err := env.Query(shared.CDCFlowStateQuery, connectionGen.FlowJobName)
 		if err == nil {
 			var state peerflow.CDCFlowWorkflowState
 			err = response.Get(&state)