diff --git a/.github/workflows/dispatch_turbine_go_dependency.yml b/.github/workflows/dispatch_turbine_go_dependency.yml
index 6d2c512a9..828414992 100644
--- a/.github/workflows/dispatch_turbine_go_dependency.yml
+++ b/.github/workflows/dispatch_turbine_go_dependency.yml
@@ -25,7 +25,7 @@ jobs:
           git config --global url."https://${MEROXA_MACHINE}:x-oauth-basic@github.com/".insteadOf "https://github.com/"
       - name: Update Dependencies
         run: |
-          go get -u github.com/meroxa/turbine-go@latest
+          go get -u github.com/meroxa/turbine-go/v2@latest
           make gomod
       - name: Generate Branch name
         id: branch
@@ -46,4 +46,4 @@ jobs:
           github_token: ${{ secrets.MEROXA_MACHINE }}
           pr_label: "ktlo,ready for review"
           pr_title: "chore: Upgrade to latest turbine-go"
-          pr_body: "The following commands were run to generate changes: go get -u github.com/meroxa/turbine-go@latest and make gomod"
\ No newline at end of file
+          pr_body: "The following commands were run to generate changes: go get -u github.com/meroxa/turbine-go/v2@latest and make gomod"
\ No newline at end of file
diff --git a/cmd/meroxa/turbine/golang/version.go b/cmd/meroxa/turbine/golang/version.go
index 6d63190eb..225ec922d 100644
--- a/cmd/meroxa/turbine/golang/version.go
+++ b/cmd/meroxa/turbine/golang/version.go
@@ -14,7 +14,7 @@ func (t *turbineGoCLI) GetVersion(ctx context.Context) (string, error) {
 	cmd = exec.CommandContext(
 		ctx,
 		"go",
-		"list", "-m", "-f", "'{{ .Version }}'", "github.com/meroxa/turbine-go")
+		"list", "-m", "-f", "'{{ .Version }}'", "github.com/meroxa/turbine-go/v2")
 	cmd.Dir = t.appPath
 	fmtErr := fmt.Errorf(
 		"unable to determine the version of turbine-go used by the Meroxa Application at %s",