change banner

Author: zhaochenyang20

README.md

@@ -135,6 +135,9 @@ with open("output.png", "wb") as f:
 print("Saved to output.png")
 
 # Video generation request
+# Note that Qwen-Image does not support video generation,
+# so this request will fail.
+
 resp = requests.post(f"{ROUTER}/v1/videos", json={
     "model": "Qwen/Qwen-Image",
     "prompt": "a flowing river",
@@ -206,8 +209,6 @@ curl -X POST http://localhost:30081/update_weights_from_disk \
     -d '{"model_path": "Qwen/Qwen-Image-2512"}'
 ```
 
----
-
 ## Router API
 
 ### Inference Endpoints
@@ -246,7 +247,7 @@ Video query routing is stable by `video_id`: router caches `video_id -> worker`
 | `PUT` | `/workers/{worker_id}` | Update worker configuration |
 | `DELETE` | `/workers/{worker_id}` | Deregister a worker |
 
-`worker_id` is the URL-encoded worker URL.
+`worker_id` is the URL-encoded worker URL (machine-oriented), and each worker payload also includes `display_id` as a human-readable ID.
 
 `PUT /workers/{worker_id}` currently supports:
 - `is_dead` (boolean): quarantine (`true`) or recover (`false`) this worker.
@@ -258,7 +259,6 @@ Video query routing is stable by `video_id`: router caches `video_id -> worker`
 |---|---|---|
 | `POST` | `/update_weights_from_disk` | Reload weights from disk on all healthy workers |
 
----
 
 ## Acknowledgment
 

examples/local_launcher.yaml

@@ -1,7 +1,7 @@
 launcher:
   model: Qwen/Qwen-Image
 
-  num_workers: 1
+  num_workers: 8
   num_gpus_per_worker: 1
   worker_host: "127.0.0.1"
   worker_base_port: 10090

src/sglang_diffusion_routing/cli/main.py

@@ -24,10 +24,10 @@ def _print_fired_up_banner(log_prefix: str) -> None:
                                 |___/
 
   ____             _            _____                _
- |  _ \ ___  _   _| |_ ___ _ _ |  ___(_)_ __ ___  __| |   _   _ _ __
- | |_) / _ \| | | | __/ _ \ '__| |_  | | '__/ _ \/ _` |  | | | | '_ \
+ |  _ \ ___  _   _| |_ ___ ____|  ___(_)_ __ ___  __| |   _   _ _ __
+ | |_) / _ \| | | | __/ _ \  __| |_  | | '__/ _ \/ _` |  | | | | '_ \
  |  _ < (_) | |_| | ||  __/ |  |  _| | | | |  __/ (_| |  | |_| | |_) |
- |_| \_\___/ \__,_|\__\___|_|  |_|   |_|_|  \___|\__,_|  |\__,_| .__/
+ |_| \_\___/ \__,_|\__\___|_|  |_|   |_|_|  \___|\__,_|   \__,_| .__/
                                                                |_|
 
 """

src/sglang_diffusion_routing/router/diffusion_router.py

@@ -469,9 +469,18 @@ def decode_worker_id(cls, worker_id: str) -> str:
             raise ValueError("worker_id cannot be empty")
         return cls.normalize_worker_url(decoded)
 
+    @staticmethod
+    def build_worker_display_id(worker_url: str) -> str:
+        """Build a human-readable worker identifier from URL."""
+        parsed = urlsplit(worker_url)
+        if parsed.netloc:
+            return parsed.netloc
+        return worker_url
+
     def _build_worker_payload(self, worker_url: str) -> dict:
         return {
             "worker_id": self.encode_worker_id(worker_url),
+            "display_id": self.build_worker_display_id(worker_url),
             "url": worker_url,
             "active_requests": self.worker_request_counts.get(worker_url, 0),
             "is_dead": worker_url in self.dead_workers,