+ {/* Header */}
+
+
+
+
+ KhulnaSoft AI Compute Grid
+
+
+ Governance & Multi-Agent Control Plane • v5.5 (Enterprise)
+
+
+
+
+
+
+
+
+
+
+ {/* Stats Grid */}
+
+
+
+
+
+
+
+ {/* Main View Area */}
+
+ {viewMode === 'grid' && (
+
+ )}
+
+ {viewMode === 'intelligence' && (
+
+ )}
+
+ {viewMode === 'governance' && (
+
+ )}
+
+
+ {/* Extended Timeline View */}
+
+
+ {/* Charts Section */}
+
+
+
+
+
+ Queue Pressure
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ Compute Utilization
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
Agent Knowledge Space
+
Vector DB Clustering (ChromaDB)
+
+
+ {Object.keys(COLORS).map(type => (
+
+ ))}
+
+
+
+
+
+
+
+
+
+
+
+ {MOCK_MEMORY.map((entry, index) => (
+ |
+ ))}
+
+
+
+
+
+
+ Total Knowledge Nodes: 1,248
+ Similarity Threshold: 0.85
+
+
+
+
+
Usage & Quotas
+
Multi-Tenancy Enforcement
+
+
+
+
+
+
+
+ GPU Hours
+ {MOCK_QUOTAS.used} / {MOCK_QUOTAS.limit}h
+
+
+
80 ? 'bg-amber-500' : 'bg-blue-500'}`}
+ style={{ width: `${gpuProgress}%` }}
+ />
+
+
+
+
+
+ Cost Burn
+ ${MOCK_QUOTAS.cost_used} / ${MOCK_QUOTAS.cost_limit}
+
+
+
+
+
+
+
+
+ Your current tier allows for 60 requests/min across all grid namespaces.
+ Auto-refill occurs at 00:00 UTC.
+
+
+
+
+
+ );
+}
diff --git a/ui/src/index.css b/ui/src/index.css
new file mode 100644
index 0000000..c60ff68
--- /dev/null
+++ b/ui/src/index.css
@@ -0,0 +1,37 @@
+@tailwind base;
+@tailwind components;
+@tailwind utilities;
+
+:root {
+ font-family: Inter, system-ui, Avenir, Helvetica, Arial, sans-serif;
+ line-height: 1.5;
+ font-weight: 400;
+
+ color-scheme: dark;
+ color: rgba(255, 255, 255, 0.87);
+ background-color: #09090b;
+
+ font-synthesis: none;
+ text-rendering: optimizeLegibility;
+ -webkit-font-smoothing: antialiased;
+ -moz-osx-font-smoothing: grayscale;
+}
+
+body {
+ margin: 0;
+ display: flex;
+ min-width: 320px;
+ min-height: 100vh;
+}
+
+#root {
+ width: 100%;
+}
+
+/* Custom Glassmorphism */
+.glass {
+ background: rgba(24, 24, 27, 0.7);
+ backdrop-filter: blur(12px);
+ -webkit-backdrop-filter: blur(12px);
+ border: 1px solid rgba(255, 255, 255, 0.1);
+}
diff --git a/ui/src/main.tsx b/ui/src/main.tsx
new file mode 100644
index 0000000..3d7150d
--- /dev/null
+++ b/ui/src/main.tsx
@@ -0,0 +1,10 @@
+import React from 'react'
+import ReactDOM from 'react-dom/client'
+import App from './App.tsx'
+import './index.css'
+
+ReactDOM.createRoot(document.getElementById('root')!).render(
+
+
+ ,
+)
diff --git a/ui/tailwind.config.js b/ui/tailwind.config.js
new file mode 100644
index 0000000..c127ac0
--- /dev/null
+++ b/ui/tailwind.config.js
@@ -0,0 +1,22 @@
+/** @type {import('tailwindcss').Config} */
+export default {
+ content: [
+ "./index.html",
+ "./src/**/*.{js,ts,jsx,tsx}",
+ ],
+ theme: {
+ extend: {
+ colors: {
+ background: "#09090b",
+ foreground: "#fafafa",
+ primary: "#3b82f6",
+ secondary: "#18181b",
+ accent: "#f43f5e",
+ },
+ animation: {
+ 'pulse-slow': 'pulse 4s cubic-bezier(0.4, 0, 0.6, 1) infinite',
+ }
+ },
+ },
+ plugins: [],
+}
From eb248832f754f8454af63e671ce5aed302529507 Mon Sep 17 00:00:00 2001
From: fortishield <161459699+FortiShield@users.noreply.github.com>
Date: Thu, 16 Apr 2026 12:25:49 +0600
Subject: [PATCH 3/6] Create deploy.yml
---
.github/workflows/deploy.yml | 52 ++++++++++++++++++++++++++++++++++++
1 file changed, 52 insertions(+)
create mode 100644 .github/workflows/deploy.yml
diff --git a/.github/workflows/deploy.yml b/.github/workflows/deploy.yml
new file mode 100644
index 0000000..61f5e6a
--- /dev/null
+++ b/.github/workflows/deploy.yml
@@ -0,0 +1,52 @@
+name: KhulnaSoft AI Compute Grid - Deploy
+
+on:
+ push:
+ branches: [ main ]
+ paths:
+ - 'platform/**'
+ - 'runtime/**'
+ - 'infra/k8s/**'
+ pull_request:
+ branches: [ main ]
+
+jobs:
+ build-and-push:
+ runs-on: ubuntu-latest
+ steps:
+ - uses: actions/checkout@v3
+
+ - name: Set up Docker Buildx
+ uses: docker/setup-buildx-action@v2
+
+ - name: Login to DockerHub
+ uses: docker/login-action@v2
+ with:
+ username: ${{ secrets.DOCKERHUB_USERNAME }}
+ password: ${{ secrets.DOCKERHUB_TOKEN }}
+
+ - name: Build and push AI Worker Image
+ uses: docker/build-push-action@v4
+ with:
+ context: .
+ file: runtime/images/worker.Dockerfile
+ push: true
+ tags: khulnasoft/ai-worker:latest
+
+ deploy-to-k8s:
+ needs: build-and-push
+ runs-on: ubuntu-latest
+ if: github.ref == 'refs/heads/main'
+ steps:
+ - uses: actions/checkout@v3
+
+ - name: Set up Kubeconfig
+ run: |
+ mkdir -p ~/.kube
+ echo "${{ secrets.KUBECONFIG }}" | base64 -d > ~/.kube/config
+
+ - name: Deploy Infrastructure
+ run: |
+ kubectl apply -f infra/k8s/gpu/device-plugin.yaml
+ kubectl apply -f infra/k8s/ray/head.yaml
+ kubectl apply -f infra/k8s/ray/worker.yaml
From 8b7f8a02d0d3d27fbb49b6718857bad93bf03ac0 Mon Sep 17 00:00:00 2001
From: xeondesk
Date: Sun, 26 Apr 2026 01:54:55 +0600
Subject: [PATCH 4/6] Update runtime/ray/worker_task.py
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
---
runtime/ray/worker_task.py | 22 +++++++++++++++-------
1 file changed, 15 insertions(+), 7 deletions(-)
diff --git a/runtime/ray/worker_task.py b/runtime/ray/worker_task.py
index 432ee4c..c4b0a21 100644
--- a/runtime/ray/worker_task.py
+++ b/runtime/ray/worker_task.py
@@ -11,14 +11,22 @@
# In production, this would be set via environment variable
RAY_ADDRESS = os.getenv("RAY_ADDRESS", "auto")
-try:
- ray.init(address=RAY_ADDRESS)
- logger.info(f"Connected to Ray cluster at {RAY_ADDRESS}")
-except Exception as e:
- logger.error(f"Failed to connect to Ray: {str(e)}")
- # Fallback to local execution for testing
- ray.init()
+def ensure_ray_initialized():
+ if ray.is_initialized():
+ return
+ try:
+ ray.init(address=RAY_ADDRESS)
+ logger.info(f"Connected to Ray cluster at {RAY_ADDRESS}")
+ except Exception as e:
+ logger.exception("Failed to connect to Ray cluster")
+ raise RuntimeError("Ray cluster initialization failed") from e
+`@ray.remote`(num_gpus=1)
+def run_ai_compute_task(payload):
+
+def main():
+ ensure_ray_initialized()
+ # Example usage
@ray.remote(num_gpus=1)
def run_ai_compute_task(payload):
"""
From 7012cce74dd120e141860fa316ef4fc43153348f Mon Sep 17 00:00:00 2001
From: xeondesk
Date: Sun, 26 Apr 2026 01:55:33 +0600
Subject: [PATCH 5/6] Update platform/scheduler/locks.py
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
---
platform/scheduler/locks.py | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/platform/scheduler/locks.py b/platform/scheduler/locks.py
index 7ad7641..4478805 100644
--- a/platform/scheduler/locks.py
+++ b/platform/scheduler/locks.py
@@ -37,14 +37,14 @@ def release(self):
"""
r.eval(script, 1, self.lock_name, self.token)
-@contextmanager
+`@contextmanager`
def distributed_lock(name, timeout=5, expire=15):
lock = RedisLock(name, timeout, expire)
- if lock.acquire():
- try:
- yield
- finally:
- lock.release()
- else:
+ acquired = lock.acquire()
+ if not acquired:
logger.warning(f"Could not acquire lock: {name}")
- yield False
+ raise RuntimeError(f"Failed to acquire distributed lock: {name}")
+ try:
+ yield
+ finally:
+ lock.release()
From 6d0d2234181174220e69afc7c1802dced815cfff Mon Sep 17 00:00:00 2001
From: xeondesk
Date: Sun, 26 Apr 2026 01:56:15 +0600
Subject: [PATCH 6/6] Update platform/scheduler/scheduler.py
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
---
platform/scheduler/scheduler.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/platform/scheduler/scheduler.py b/platform/scheduler/scheduler.py
index 0b74566..8210438 100644
--- a/platform/scheduler/scheduler.py
+++ b/platform/scheduler/scheduler.py
@@ -8,14 +8,14 @@
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger("Scheduler")
-r = redis.Redis(host="redis", port=6379, decode_responses=True)
+REDIS_HOST = "redis"
+REDIS_PORT = 6379
+r = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, decode_responses=True)
from platform.scheduler.state import get_active_nodes, update_node_status
from platform.scheduler.lifecycle import transition_job, fail_job
from platform.scheduler.resource_manager import get_required_resources, find_best_node
-r = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, decode_responses=True)
-
def dispatch(cluster_type, job_data, node_id):
"""
Dispatches the job to a specific node with lifecycle tracking.