global executors / worker pools with automatic shutdown semantics."""
from __future__ import annotations
-
import concurrent.futures as fut
import logging
import os
if bundle_to_backup is not None:
self.last_backup = now
logger.info(
- '=====> SCHEDULING BACKUP %s (score=%.1f}) <=====',
+ '=====> SCHEDULING BACKUP %s (score=%.1f) <=====',
bundle_to_backup,
best_score,
)
RemoteWorkerRecord(
username='scott',
machine='cheetah.house',
- weight=30,
- count=6,
+ weight=24,
+ count=5,
),
)
if self.ping('meerkat.cabin'):
RemoteWorkerRecord(
username='scott',
machine='wannabe.house',
- weight=25,
- count=10,
+ weight=14,
+ count=2,
),
)
if self.ping('puma.cabin'):
RemoteWorkerRecord(
username='scott',
machine='puma.cabin',
- weight=30,
- count=6,
+ weight=24,
+ count=5,
),
)
if self.ping('backup.house'):
RemoteWorkerRecord(
username='scott',
machine='backup.house',
- weight=8,
+ weight=9,
count=2,
),
)