diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go
index 25b8997a..50910006 100644
--- a/functions/onprem/worker/worker.go
+++ b/functions/onprem/worker/worker.go
@@ -2565,7 +2565,7 @@ func getWorkerBackendExecution(auth string, executionId string) (*shuffle.Workfl
 		log.Printf("[INFO] Here is the result we got back from backend: %s", workflowExecution.Results)
 	}
 
-	setWorkflowExecution(context.Background(), *workflowExecution, false)
+	//setWorkflowExecution(context.Background(), *workflowExecution, false)
 	return workflowExecution, nil
 }
 
@@ -3049,16 +3049,13 @@ func handleGetStreamResults(resp http.ResponseWriter, request *http.Request) {
 	workflowExecution, err := shuffle.GetWorkflowExecution(ctx, actionResult.ExecutionId)
 	if err != nil {
 		log.Printf("[WARNING][%s] Failed to find execution in cache requesting backend (4): %s", actionResult.ExecutionId, err)
-		return
-	
-	//  This was causing the worker to take over parent execution in hybrid mode
-	//	workflowExecution, err = getWorkerBackendExecution(actionResult.Authorization, actionResult.ExecutionId)
-	//	if err != nil {
-	//		log.Printf("[ERROR] Failed getting execution (streamresult) %s: %s", actionResult.ExecutionId, err)
-	//		resp.WriteHeader(400)
-	//		resp.Write([]byte(fmt.Sprintf(`{"success": false, "reason": "Bad authorization key or execution_id might not exist."}`)))
-	//		return
-	//	}
+		workflowExecution, err = getWorkerBackendExecution(actionResult.Authorization, actionResult.ExecutionId)
+		if err != nil {
+			log.Printf("[ERROR] Failed getting execution (streamresult) %s: %s", actionResult.ExecutionId, err)
+			resp.WriteHeader(400)
+			resp.Write([]byte(fmt.Sprintf(`{"success": false, "reason": "Bad authorization key or execution_id might not exist."}`)))
+			return
+		}
 	}
 
 	// Authorization is done here