def make_cloud_pickle(fun, *args, **kwargs):
- logger.info(f"Making cloudpickled bundle at {fun.__name__}")
+ logger.debug(f"Making cloudpickled bundle at {fun.__name__}")
return cloudpickle.dumps((fun, args, kwargs))
while True:
try:
- p.wait(timeout=0.5)
+ p.wait(timeout=0.25)
except subprocess.TimeoutExpired:
self.heartbeat()
RemoteWorkerRecord(
username = 'scott',
machine = 'meerkat.cabin',
- weight = 7,
+ weight = 6,
count = 2,
),
)