Add more test code

beam-cloud · Jan 9, 2025 · e5f7979 · e5f7979
1 parent 164a70d
commit e5f7979
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/pkg/abstractions/image/image.go b/pkg/abstractions/image/image.go
@@ -214,7 +214,7 @@ func (is *RuncImageService) monitorImageContainers(ctx context.Context) {
 			case common.KeyOperationSet:
 				if strings.Contains(event.Key, common.RedisKeys.SchedulerContainerState("")) {
 					containerId := strings.TrimPrefix(is.keyEventManager.TrimKeyspacePrefix(event.Key), common.RedisKeys.SchedulerContainerState(""))
-					log.Printf("CONTAINER_ID_ssIS: %s", containerId)
+					log.Printf("CONTAINER_ID_ssIsS: %s", containerId)
 					if is.rdb.Exists(ctx, Keys.imageBuildContainerTTL(containerId)).Val() == 0 {
 						is.builder.scheduler.Stop(&types.StopContainerArgs{
 							ContainerId: containerId,

diff --git a/pkg/scheduler/pool_local.go b/pkg/scheduler/pool_local.go
@@ -152,7 +152,8 @@ func (wpc *LocalKubernetesWorkerPoolController) createWorkerJob(workerId string,
 	workerImage := fmt.Sprintf("%s/%s:%s",
 		wpc.config.Worker.ImageRegistry,
 		wpc.config.Worker.ImageName,
-		wpc.config.Worker.ImageTag,
+		// wpc.config.Worker.ImageTag,
+		"devel",
 	)
 
 	resources := corev1.ResourceRequirements{}

diff --git a/pkg/worker/runc_server.go b/pkg/worker/runc_server.go
@@ -118,6 +118,7 @@ func (s *RunCServer) RunCExec(ctx context.Context, in *pb.RunCExecRequest) (*pb.
 
 	err = s.runcHandle.Exec(ctx, in.ContainerId, *process, &runc.ExecOpts{
 		OutputWriter: instance.OutputWriter,
+		Detach:       true,
 	})
 
 	return &pb.RunCExecResponse{