Finish

Author: OneSizeFitsQuorum

Dockerfile

@@ -0,0 +1,11 @@
+FROM linuxserver/code-server:4.101.2
+
+RUN sudo apt-get update && apt-get install -y software-properties-common && sudo add-apt-repository ppa:deadsnakes/ppa && apt-get install -y python3 python3-pip && pip3 install ray[default] debugpy --break-system-packages
+
+RUN mkdir -p /config/extensions \
+    && curl -L -o /config/extensions/ms-python.python.vsix https://marketplace.visualstudio.com/_apis/public/gallery/publishers/ms-python/vsextensions/python/2025.10.0/vspackage \
+    && curl -L -o /config/extensions/ms-python.debugpy.vsix https://marketplace.visualstudio.com/_apis/public/gallery/publishers/ms-python/vsextensions/debugpy/2025.10.0/vspackage \
+    && curl -L -o /config/extensions/anyscalecompute.ray-distributed-debugger.vsix https://marketplace.visualstudio.com/_apis/public/gallery/publishers/anyscalecompute/vsextensions/ray-distributed-debugger/0.1.4/vspackage \
+    && /app/code-server/bin/code-server --extensions-dir /config/extensions --install-extension ms-python.python \
+    && /app/code-server/bin/code-server --extensions-dir /config/extensions --install-extension ms-python.debugpy \
+    && /app/code-server/bin/code-server --extensions-dir /config/extensions --install-extension anyscalecompute.ray-distributed-debugger

README.en.md

@@ -0,0 +1,7 @@
+import ray
+
+@ray.remote
+def f(x):
+    print(x)
+    breakpoint()
+    return x * x

README.md

@@ -0,0 +1,74 @@
+apiVersion: ray.io/v1
+kind: RayJob
+metadata:
+  name: rayjob-interactive-mode
+spec:
+  # InteractiveMode means KubeRay doesn't submit the job for you.
+  # KubeRay will create the RayJob and transition it to the Waiting state.
+  # The user needs to submit the job manually via the `ray job submit` command
+  # and then update the `spec.jobId` field with the job ID.
+  # After that, KubeRay will handle the rest of the lifecycle for the RayJob.
+  submissionMode: InteractiveMode
+  # User needs to update this field with the job ID after submitting the job
+  jobId: ""
+  rayClusterSpec:
+    headGroupSpec:
+      rayStartParams: {}
+      template:
+        spec:
+          containers:
+          - image: rayproject/ray:2.46.0
+            name: ray-head
+            ports:
+            - containerPort: 6379
+              name: gcs-server
+            - containerPort: 8265
+              name: dashboard
+            - containerPort: 10001
+              name: client
+            resources:
+              limits:
+                cpu: "500m"
+              requests:
+                cpu: "200m"
+            volumeMounts:
+              - mountPath: /tmp/ray
+                name: shared-ray-volume
+          - name: vscode-debugger
+            image: docker.io/onesizefitsquorum/code-server-with-ray-distributed-debugger:4.101.2
+            imagePullPolicy: IfNotPresent
+            ports:
+              - containerPort: 8443
+            volumeMounts:
+              - mountPath: /tmp/ray
+                name: shared-ray-volume
+            env:
+              - name: PUID
+                value: "1000"
+              - name: PGID
+                value: "1000"
+              - name: TZ
+                value: "Asia/Shanghai"
+              - name: DEFAULT_WORKSPACE
+                value: "/tmp/ray/session_latest/runtime_resources"
+              - name: SUDO_PASSWORD
+                value: "root"
+          volumes:
+            - name: shared-ray-volume  # Shared volume for /tmp/ray
+              emptyDir: {} 
+    workerGroupSpecs:
+    - groupName: default-group
+      replicas: 1
+      minReplicas: 1
+      maxReplicas: 1
+      rayStartParams: {}
+      template:
+        spec:
+          containers:
+          - image: rayproject/ray:2.46.0
+            name: ray-worker
+            resources:
+              limits:
+                cpu: "500m"
+              requests:
+                cpu: "200m"

example/dependency/__init__.py

@@ -0,0 +1,10 @@
+import ray
+
+ray.init()
+
+from dependency.dependency import f
+
+futures = [f.remote(i) for i in range(4)]
+
+breakpoint()
+print(ray.get(futures)) # [0, 1, 4, 9]