Upload Quasar_axrvi_ranker.py

Quasar_axrvi_ranker.py

@@ -4550,7 +4550,7 @@ class QuasarAXRVIBridge:
         reward_strategy: str  = "simple",
         hub_ws_url:      str  = os.environ.get("QUASAR_HUB_URL", "ws://localhost:7860/ws/subscribe"),
         enable_logging:  bool = True,
-        checkpoint_dir:  str  = "./Ranker3",   # folder for full-state checkpoints
+        checkpoint_dir:  str  = "./Ranker4",   # folder for full-state checkpoints
         resume:          bool = False,         # start afresh by default; set True to resume
     ):
         self.config          = config or AssetRankerConfig()
@@ -6204,7 +6204,7 @@ class RankerCheckpointManager:
                On load, missing local files are pulled from the repo first.
                Requires HF_TOKEN env-var with write permission.
 
-    Fallback : Local disk  ./Ranker3/
+    Fallback : Local disk  ./Ranker4/
                Used when HF_TOKEN is absent or upload/download fails.
                All saves still succeed locally even without network access.
 
@@ -6258,7 +6258,7 @@ class RankerCheckpointManager:
 
     Usage
     ─────
-    mgr = RankerCheckpointManager(checkpoint_dir="./Ranker3",
+    mgr = RankerCheckpointManager(checkpoint_dir="./Ranker4",
                                    save_interval_seconds=1800)
     mgr.load(bridge)              # once after initialize()
     mgr.maybe_save(bridge)        # call frequently; respects save_interval_seconds
@@ -6274,7 +6274,7 @@ class RankerCheckpointManager:
 
     def __init__(
         self,
-        checkpoint_dir:         str   = "./Ranker3",
+        checkpoint_dir:         str   = "./Ranker4",
         save_interval_seconds:  float = 1800.0,   # 30 minutes
     ):
         import pathlib
@@ -6328,7 +6328,7 @@ class RankerCheckpointManager:
             )
             logger.info(
                 f"[RankerCheckpoint] ☁️  Uploaded {local_path.name} → "
-                f"hf://{self.HF_REPO_ID}/Ranker3/{local_path.name}"
+                f"hf://{self.HF_REPO_ID}/Ranker4/{local_path.name}"
             )
             return True
         except Exception as exc:
@@ -6359,7 +6359,7 @@ class RankerCheckpointManager:
             )
             logger.info(
                 f"[RankerCheckpoint] ⬇️  Downloaded {filename} from "
-                f"hf://{self.HF_REPO_ID}/Ranker3/"
+                f"hf://{self.HF_REPO_ID}/Ranker4/"
             )
             return True
         except Exception as exc:
@@ -6900,7 +6900,7 @@ async def run_live_trading_system(
     hub_ws_url:      str  = "ws://localhost:7860/ws/subscribe",
     enable_logging:  bool = True,
     shreve_config:   Optional[ShreveConfig] = None,
-    checkpoint_dir:  str  = "./Ranker3",
+    checkpoint_dir:  str  = "./Ranker4",
     resume:          bool = False,   # start fresh by default
 ) -> None:
     config = AssetRankerConfig(
@@ -7212,8 +7212,8 @@ def _parse_args():
                         help="[S6/S8] Trade horizon τ in seconds (default 60)")
     parser.add_argument("--martingale-epsilon", type=float, default=0.05,
                         help="[S7] Gate E martingale deviation threshold (default 0.05)")
-    parser.add_argument("--checkpoint-dir", default="./Ranker3",
-                        help="Directory for full-state checkpoints (default ./Ranker3)")
+    parser.add_argument("--checkpoint-dir", default="./Ranker4",
+                        help="Directory for full-state checkpoints (default ./Ranker4)")
     parser.add_argument("--resume", action="store_true",
                         help="Resume training from the latest saved checkpoint (default: start fresh)")
     return parser.parse_args(filtered)