db88bca (#499)

* build(deps): bump github.com/argoproj/argo-workflows/v3

Bumps [github.com/argoproj/argo-workflows/v3](https://github.com/argoproj/argo-workflows) from 3.5.13 to 3.6.12.
- [Release notes](https://github.com/argoproj/argo-workflows/releases)
- [Changelog](https://github.com/argoproj/argo-workflows/blob/main/CHANGELOG.md)
- [Commits](argoproj/argo-workflows@v3.5.13...v3.6.12)

---
updated-dependencies:
- dependency-name: github.com/argoproj/argo-workflows/v3
  dependency-version: 3.6.12
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>

* Update header keys to be case-sensitive (#482)

Co-authored-by: Haihui.Wang <hh.wang@opencsg.com>

* Read clusterIP if no ingress IP found when server and runner are running in same cluster (#484)

Co-authored-by: Haihui.Wang <hh.wang@opencsg.com>

* > [rproxy] Wrong way to set svc host name in header for v1.12 release (#485)

Co-authored-by: Haihui.Wang <hh.wang@opencsg.com>

* Fix lfs sync upload id cache bug (#489)

* Add User-Email to request headers for dataflow and label studio (#492)

Co-authored-by: Haihui.Wang <hh.wang@opencsg.com>

* fix(imagebuilder): correct remote endpoint retrieval logic in stop function

* Refactor Deploy Scheduler, Migrate to Temporal Workflow

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: HaiHui <154984842+HaiHui886@users.noreply.github.com>
Co-authored-by: Haihui.Wang <hh.wang@opencsg.com>
Co-authored-by: vincent <pulltheflower@163.com>
Co-authored-by: ruibo.qin <rb.qin@opencsg.com>

Author: 6 people

_mocks/opencsg.com/csghub-server/builder/store/database/mock_ArgoWorkFlowStore.go

@@ -60,6 +60,7 @@ func (h *DataflowProxyHandler) Proxy(ctx *gin.Context) {
 	ctx.Request.Header.Set("User-Id", fmt.Sprintf("%d", u.ID))
 	ctx.Request.Header.Set("User-Name", u.Username)
 	ctx.Request.Header.Set("User-Token", token)
+	ctx.Request.Header.Set("User-Email", u.Email)
 	ctx.Request.Header.Set("isadmin", fmt.Sprintf("%t", u.CanAdmin()))
 	// Log the request URL and header
 	slog.Debug("http request", slog.Any("request", ctx.Request.URL), slog.Any("header", ctx.Request.Header))

_mocks/opencsg.com/csghub-server/builder/store/database/mock_DeployTaskStore.go

@@ -19,16 +19,24 @@ import (
 	"opencsg.com/csghub-server/api/handler/callback"
 	"opencsg.com/csghub-server/api/httpbase"
 	"opencsg.com/csghub-server/api/middleware"
+	"opencsg.com/csghub-server/api/workflow"
+	"opencsg.com/csghub-server/builder/deploy"
 	"opencsg.com/csghub-server/builder/instrumentation"
 	bldmq "opencsg.com/csghub-server/builder/mq"
 	bldprometheus "opencsg.com/csghub-server/builder/prometheus"
+	"opencsg.com/csghub-server/builder/store/database"
 	"opencsg.com/csghub-server/builder/temporal"
 	"opencsg.com/csghub-server/common/config"
 	"opencsg.com/csghub-server/common/i18n"
 	"opencsg.com/csghub-server/common/types"
 )
 
 func RunServer(config *config.Config, enableSwagger bool) {
+	deploy.DeployWorkflow = func(buildTask, runTask *database.DeployTask) {
+		if err := workflow.StartNewDeployTaskWithCancelOld(buildTask, runTask); err != nil {
+			slog.Error("start new deploy task failed", slog.Any("error", err))
+		}
+	}
 	stopOtel, err := instrumentation.SetupOTelSDK(context.Background(), config, instrumentation.Server)
 	if err != nil {
 		panic(err)