X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=executors.py;h=b243edd29b02cfa4b4689e515f3901e4bef2fd5c;hb=0bc6e4312cad0f997751739e750954ac39dfa6cc;hp=63efd812e54b5b796daff892f9ff1e75fd4e6569;hpb=b10d30a46e601c9ee1f843241f2d69a1f90f7a94;p=python_utils.git

diff --git a/executors.py b/executors.py
index 63efd81..b243edd 100644
--- 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,
                     ),
                 )