diff --git a/server/package-lock.json b/server/package-lock.json
index 906f5d8e57..da67bf2a59 100644
--- a/server/package-lock.json
+++ b/server/package-lock.json
@@ -1,12 +1,12 @@
 {
   "name": "@scrypted/server",
-  "version": "0.123.31",
+  "version": "0.123.32",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@scrypted/server",
-      "version": "0.123.31",
+      "version": "0.123.32",
       "hasInstallScript": true,
       "license": "ISC",
       "dependencies": {
diff --git a/server/python/cluster_labels.py b/server/python/cluster_labels.py
index b6b7708072..6250d1af61 100644
--- a/server/python/cluster_labels.py
+++ b/server/python/cluster_labels.py
@@ -6,6 +6,7 @@ class ClusterForkOptions(TypedDict):
     runtime: Optional[str]
     labels: Optional[Dict[str, List[str]]]
     id: Optional[str]
+    clusterWorkerId: Optional[str]
 
 
 def matches_cluster_labels(options: ClusterForkOptions, labels: List[str]) -> int:
@@ -46,6 +47,5 @@ def needs_cluster_fork_worker(options: ClusterForkOptions) -> bool:
     return (
         os.environ.get("SCRYPTED_CLUSTER_ADDRESS")
         and options
-        and options.get("runtime", None)
-        and not matches_cluster_labels(options, get_cluster_labels())
+        and (not matches_cluster_labels(options, get_cluster_labels()) or options.get("clusterWorkerId", None))
     )