Fix CI regressions after upstream sync

Signed-off-by: Eitan Yarmush <eitan.yarmush@solo.io>

Author: EItanya

charts/substrate/templates/sandboxconfig-gvisor.yaml

@@ -14,18 +14,15 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */}}
 
-# Cluster-wide default SandboxConfig for the gVisor (runsc) sandbox class. A
-# WorkerPool with sandboxClass gvisor (the default) and no explicit
-# sandboxConfigName resolves to this. atelet fetches the runsc binary matching
-# the worker node's architecture. To pin a different runsc, edit the assets
-# below or create another SandboxConfig and name it from the WorkerPool.
+# Cluster-wide SandboxConfig for the gVisor (runsc) sandbox class, shipped with
+# the platform so gVisor ActorTemplates have a config to name via
+# sandboxConfig.configName.
 apiVersion: ate.dev/v1alpha1
 kind: SandboxConfig
 metadata:
   name: gvisor-default
 spec:
   sandboxClass: gvisor
-  default: true
   pauseImage: "registry.k8s.io/pause:3.10.2@sha256:f548e0e8e3dc1896ca956272154dde3314e8cc4fde0a57577ee9fa1c63f5baf4"
   assets:
     amd64:

cmd/ateapi/internal/controlapi/workflow_pause.go

@@ -237,13 +237,16 @@ func (w *ActorWorkflow) ensurePausedFinalized(ctx context.Context, actorRef reso
 			nodeName = worker.GetNodeName()
 			// Drop just this actor's assignment; any other actors the worker
 			// hosts keep theirs.
-			_, err := w.store.ReleaseActorFromWorker(ctx, worker.GetMetadata().GetName(), latestActor.GetMetadata().GetUid())
+			released, err := w.store.ReleaseActorFromWorker(ctx, worker.GetMetadata().GetName(), latestActor.GetMetadata().GetUid())
 			if err != nil {
 				if errors.Is(err, store.ErrVersionConflict) {
 					return nil, status.Error(codes.Aborted, "concurrent update conflict, please retry")
 				}
 				return nil, err
 			}
+			if w.workerCache != nil {
+				w.workerCache.Observe(released)
+			}
 		}
 
 		// 2. Clear the actor's assignment, now that the worker is freed

cmd/ateapi/internal/workercache/workercache.go

@@ -120,6 +120,12 @@ func (c *Cache) Forget(name string) {
 	delete(c.workers, name)
 }
 
+// Observe applies a worker returned by a successful store write immediately,
+// without waiting for the corresponding watch event.
+func (c *Cache) Observe(worker *ateapipb.Worker) {
+	c.applyEvent(store.WorkerEvent{Type: store.WorkerEventUpdated, Worker: worker})
+}
+
 func (c *Cache) sync(ctx context.Context) (*store.WorkerWatch, error) {
 	watch, err := c.store.WatchWorkers(ctx)
 	if err != nil {