diff --git a/cluster/v9_advanced_coordinator.py b/cluster/v9_advanced_coordinator.py index 07e2cac..3da60fe 100755 --- a/cluster/v9_advanced_coordinator.py +++ b/cluster/v9_advanced_coordinator.py @@ -27,6 +27,9 @@ WORKERS = { 'host': 'root@10.20.254.100', 'workspace': '/home/backtest_dual/backtest', 'ssh_hop': 'root@10.10.254.106', + 'time_restricted': True, # Only run during off-hours due to noise + 'allowed_start_hour': 19, # 7 PM + 'allowed_end_hour': 6, # 6 AM } } @@ -289,6 +292,12 @@ def main(): # Assign work to idle workers for worker_name in WORKERS.keys(): + # Check if worker is allowed to run (time restrictions) + if not is_worker_allowed_to_run(worker_name): + if iteration % 10 == 0: # Log every 10 iterations to avoid spam + print(f"⏰ {worker_name} not allowed (office hours, noise restriction)") + continue + # Check if worker is idle (simplified: assume one chunk per worker) conn = sqlite3.connect(DB_PATH) cursor = conn.cursor()