projects
/
python_utils.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Update profanity.
[python_utils.git]
/
executors.py
diff --git
a/executors.py
b/executors.py
index 2d80c3bdd92f80862d7b2be19678c004393f3ff3..e1949fbb992fbfcc9ace61099b4140fb460644e6 100644
(file)
--- a/
executors.py
+++ b/
executors.py
@@
-10,7
+10,6
@@
Also defines DefaultExecutors which is a container for references to
global executors / worker pools with automatic shutdown semantics."""
from __future__ import annotations
global executors / worker pools with automatic shutdown semantics."""
from __future__ import annotations
-
import concurrent.futures as fut
import logging
import os
import concurrent.futures as fut
import logging
import os
@@
-705,7
+704,7
@@
class RemoteExecutor(BaseExecutor):
if bundle_to_backup is not None:
self.last_backup = now
logger.info(
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,
)
bundle_to_backup,
best_score,
)
@@
-1191,8
+1190,8
@@
class DefaultExecutors(object):
RemoteWorkerRecord(
username='scott',
machine='cheetah.house',
RemoteWorkerRecord(
username='scott',
machine='cheetah.house',
- weight=
30
,
- count=
6
,
+ weight=
24
,
+ count=
5
,
),
)
if self.ping('meerkat.cabin'):
),
)
if self.ping('meerkat.cabin'):
@@
-1211,8
+1210,8
@@
class DefaultExecutors(object):
RemoteWorkerRecord(
username='scott',
machine='wannabe.house',
RemoteWorkerRecord(
username='scott',
machine='wannabe.house',
- weight=
25
,
- count=
10
,
+ weight=
14
,
+ count=
2
,
),
)
if self.ping('puma.cabin'):
),
)
if self.ping('puma.cabin'):
@@
-1221,8
+1220,8
@@
class DefaultExecutors(object):
RemoteWorkerRecord(
username='scott',
machine='puma.cabin',
RemoteWorkerRecord(
username='scott',
machine='puma.cabin',
- weight=
30
,
- count=
6
,
+ weight=
24
,
+ count=
5
,
),
)
if self.ping('backup.house'):
),
)
if self.ping('backup.house'):
@@
-1231,7
+1230,7
@@
class DefaultExecutors(object):
RemoteWorkerRecord(
username='scott',
machine='backup.house',
RemoteWorkerRecord(
username='scott',
machine='backup.house',
- weight=
8
,
+ weight=
9
,
count=2,
),
)
count=2,
),
)