Logging + documentation.

[python_utils.git] / executors.py

diff --git a/executors.py b/executors.py
index 63efd812e54b5b796daff892f9ff1e75fd4e6569..b243edd29b02cfa4b4689e515f3901e4bef2fd5c 100644 (file)
--- a/executors.py
+++ b/executors.py
@@ -64,7 +64,7 @@ SSH = 'ssh -oForwardX11=no'
 
 
 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))
 
 
@@ -619,7 +619,7 @@ class RemoteExecutor(BaseExecutor):
 
         while True:
             try:
-                p.wait(timeout=0.5)
+                p.wait(timeout=0.25)
             except subprocess.TimeoutExpired:
                 self.heartbeat()
 
@@ -882,7 +882,7 @@ class DefaultExecutors(object):
                     RemoteWorkerRecord(
                         username = 'scott',
                         machine = 'meerkat.cabin',
-                        weight = 7,
+                        weight = 6,
                         count = 2,
                     ),
                 )