marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #1784 from yashsinghcodes/new-nightly

Browse Source 
Need this for testing.
This commit is contained in:
Yash Singh
2025-08-07 23:06:36 +05:30
committed by GitHub
parent acd2116a49 4f98b583a4
commit 57cac83a12
2 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/go-app/walkoff.go
+4 -4
View File
@@ -309,10 +309,10 @@ func handleGetWorkflowqueue(resp http.ResponseWriter, request *http.Request) {
} }
if !found { if !found {
log.Printf("[ERROR] Failed to find environment(%s) for org(%s)", environment, orgId) env, err = shuffle.GetEnvironment(ctx, environment, "")
resp.WriteHeader(400) if err != nil {
resp.Write([]byte(`{"success":false,"reason":"environment not found"}`)) log.Printf("[WARNING] Failed to find the environment(%s) in org(%s). Could cause with Failover test", environment, orgId)
return }
} }
timeNow := time.Now().Unix() timeNow := time.Now().Unix()
functions/onprem/worker/worker.go
+10 -2
View File
@@ -840,7 +840,10 @@ func deployApp(cli *dockerclient.Client, image string, identifier string, env []
// Running as coroutine for eventual completeness // Running as coroutine for eventual completeness
// FIXME: With goroutines it got too much trouble of deploying with an older version // FIXME: With goroutines it got too much trouble of deploying with an older version
// Allowing slow startups, as long as it's eventually fast, and uses the same registry as on host. // Allowing slow startups, as long as it's eventually fast, and uses the same registry as on host.
shuffle.DownloadDockerImageBackend(&http.Client{Timeout: imagedownloadTimeout}, image) err := shuffle.DownloadDockerImageBackend(&http.Client{Timeout: imagedownloadTimeout}, image)
if err == nil {
downloadedImages = append(downloadedImages, image)
}
} }
var exposedPort int var exposedPort int
@@ -1598,6 +1601,7 @@ func handleExecutionResult(workflowExecution shuffle.WorkflowExecution) {
executed := false executed := false
if err == nil { if err == nil {
log.Printf("[DEBUG] Downloaded image %s from backend (CLEANUP)", imageName) log.Printf("[DEBUG] Downloaded image %s from backend (CLEANUP)", imageName)
downloadedImages = append(downloadedImages, imageName)
//err = deployApp(dockercli, image, identifier, env, workflow, action) //err = deployApp(dockercli, image, identifier, env, workflow, action)
err = deployApp(dockercli, imageName, identifier, env, workflowExecution, action) err = deployApp(dockercli, imageName, identifier, env, workflowExecution, action)
if err != nil && !strings.Contains(err.Error(), "Conflict. The container name") { if err != nil && !strings.Contains(err.Error(), "Conflict. The container name") {
@@ -1712,6 +1716,7 @@ func handleExecutionResult(workflowExecution shuffle.WorkflowExecution) {
executed := false executed := false
if err == nil { if err == nil {
log.Printf("[DEBUG] Downloaded image %s from backend (CLEANUP)", imageName) log.Printf("[DEBUG] Downloaded image %s from backend (CLEANUP)", imageName)
downloadedImages = append(downloadedImages, imageName)
//err = deployApp(dockercli, image, identifier, env, workflow, action) //err = deployApp(dockercli, image, identifier, env, workflow, action)
err = deployApp(dockercli, imageName, identifier, env, workflowExecution, action) err = deployApp(dockercli, imageName, identifier, env, workflowExecution, action)
if err != nil && !strings.Contains(err.Error(), "Conflict. The container name") { if err != nil && !strings.Contains(err.Error(), "Conflict. The container name") {
@@ -4415,7 +4420,10 @@ func handleDownloadImage(resp http.ResponseWriter, request *http.Request) {
} }
log.Printf("[INFO] Downloading image %s", imageBody.Image) log.Printf("[INFO] Downloading image %s", imageBody.Image)
shuffle.DownloadDockerImageBackend(&http.Client{Timeout: imagedownloadTimeout}, imageBody.Image) err = shuffle.DownloadDockerImageBackend(&http.Client{Timeout: imagedownloadTimeout}, imageBody.Image)
if err == nil {
downloadedImages = append(downloadedImages, imageBody.Image)
}
// return success // return success
resp.WriteHeader(200) resp.WriteHeader(200)