[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

execnet/gateway.py

@@ -18,7 +18,7 @@
 
 
 class Gateway(gateway_base.BaseGateway):
-    """ Gateway to a local or remote Python Intepreter. """
+    """Gateway to a local or remote Python Intepreter."""
 
     def __init__(self, io, spec):
         super(Gateway, self).__init__(io=io, id=spec.id, _startcount=1)
@@ -30,7 +30,7 @@ def remoteaddress(self):
         return self._io.remoteaddress
 
     def __repr__(self):
-        """ return string representing gateway type and status. """
+        """return string representing gateway type and status."""
         try:
             r = self.hasreceiver() and "receive-live" or "not-receiving"
             i = len(self._channelfactory.channels())
@@ -72,7 +72,7 @@ def reconfigure(self, py2str_as_py3str=True, py3str_as_py2str=False):
         self._send(Message.RECONFIGURE, data=data)
 
     def _rinfo(self, update=False):
-        """ return some sys/env information from remote. """
+        """return some sys/env information from remote."""
         if update or not hasattr(self, "_cache_rinfo"):
             ch = self.remote_exec(rinfo_source)
             try:
@@ -82,11 +82,11 @@ def _rinfo(self, update=False):
         return self._cache_rinfo
 
     def hasreceiver(self):
-        """ return True if gateway is able to receive data. """
+        """return True if gateway is able to receive data."""
         return self._receivepool.active_count() > 0
 
     def remote_status(self):
-        """ return information object about remote execution status. """
+        """return information object about remote execution status."""
         channel = self.newchannel()
         self._send(Message.STATUS, channel.id)
         statusdict = channel.receive()
@@ -136,7 +136,7 @@ def remote_exec(self, source, **kwargs):
         return channel
 
     def remote_init_threads(self, num=None):
-        """ DEPRECATED.  Is currently a NO-OPERATION already."""
+        """DEPRECATED.  Is currently a NO-OPERATION already."""
         print("WARNING: remote_init_threads()" " is a no-operation in execnet-1.2")
 
 

execnet/gateway_base.py

@@ -239,7 +239,7 @@ class WorkerPool(object):
     """
 
     def __init__(self, execmodel, hasprimary=False):
-        """ by default allow unlimited number of spawns. """
+        """by default allow unlimited number of spawns."""
         self.execmodel = execmodel
         self._running_lock = self.execmodel.Lock()
         self._running = set()
@@ -316,12 +316,12 @@ def spawn(self, func, *args, **kwargs):
         return reply
 
     def terminate(self, timeout=None):
-        """ trigger shutdown and wait for completion of all executions. """
+        """trigger shutdown and wait for completion of all executions."""
         self.trigger_shutdown()
         return self.waitall(timeout=timeout)
 
     def waitall(self, timeout=None):
-        """ wait until all active spawns have finished executing. """
+        """wait until all active spawns have finished executing."""
         with self._running_lock:
             if not self._running:
                 return True
@@ -393,7 +393,7 @@ def __init__(self, outfile, infile, execmodel):
         self.execmodel = execmodel
 
     def read(self, numbytes):
-        """Read exactly 'numbytes' bytes from the pipe. """
+        """Read exactly 'numbytes' bytes from the pipe."""
         # a file in non-blocking mode may return less bytes, so we loop
         buf = bytes()
         while numbytes > len(buf):
@@ -404,7 +404,7 @@ def read(self, numbytes):
         return buf
 
     def write(self, data):
-        """write out all data bytes. """
+        """write out all data bytes."""
         assert isinstance(data, bytes)
         self._write(data)
         self.outfile.flush()
@@ -417,7 +417,7 @@ def close_write(self):
 
 
 class Message:
-    """ encapsulates Messages and their wire protocol. """
+    """encapsulates Messages and their wire protocol."""
 
     _types = []
 
@@ -453,7 +453,7 @@ def __repr__(self):
 
 
 class GatewayReceivedTerminate(Exception):
-    """ Receiverthread got termination message. """
+    """Receiverthread got termination message."""
 
 
 def _setupmessages():
@@ -525,7 +525,7 @@ def geterrortext(excinfo, format_exception=traceback.format_exception, sysex=sys
 
 
 class RemoteError(Exception):
-    """ Exception containing a stringified error from the other side. """
+    """Exception containing a stringified error from the other side."""
 
     def __init__(self, formatted):
         self.formatted = formatted
@@ -544,7 +544,7 @@ def warn(self):
 
 
 class TimeoutError(IOError):
-    """ Exception indicating that a timeout was reached. """
+    """Exception indicating that a timeout was reached."""
 
 
 NO_ENDMARKER_WANTED = object()
@@ -787,7 +787,7 @@ def __init__(self, gateway, startcount=1):
         self._list = list  # needed during interp-shutdown
 
     def new(self, id=None):
-        """ create a new Channel with 'id' (or create new id if None). """
+        """create a new Channel with 'id' (or create new id if None)."""
         with self._writelock:
             if self.finished:
                 raise IOError("connexion already closed: {}".format(self.gateway))
@@ -1011,11 +1011,11 @@ def _local_schedulexec(self, channel, sourcetask):
     # _____________________________________________________________________
     #
     def newchannel(self):
-        """ return a new independent channel. """
+        """return a new independent channel."""
         return self._channelfactory.new()
 
     def join(self, timeout=None):
-        """ Wait for receiverthread to terminate. """
+        """Wait for receiverthread to terminate."""
         self._trace("waiting for receiver thread to finish")
         self._receivepool.waitall()
 
@@ -1296,7 +1296,7 @@ def load_channel(self):
 
 
 class opcode:
-    """ container for name -> num mappings. """
+    """container for name -> num mappings."""
 
 
 def _buildopcodes():
@@ -1329,7 +1329,7 @@ def dumps(obj):
 
 
 def dump(byteio, obj):
-    """ write a serialized bytestring of the given obj to the given stream. """
+    """write a serialized bytestring of the given obj to the given stream."""
     _Serializer(write=byteio.write).save(obj, versioned=True)
 
 

execnet/multi.py

@@ -20,7 +20,7 @@
 
 
 class Group(object):
-    """ Gateway Groups. """
+    """Gateway Groups."""
 
     defaultspec = "popen"
 
@@ -163,7 +163,7 @@ def makegateway(self, spec=None):
         return gw
 
     def allocate_id(self, spec):
-        """ (re-entrant) allocate id for the given xspec object. """
+        """(re-entrant) allocate id for the given xspec object."""
         if spec.id is None:
             with self._autoidlock:
                 id = "gw" + str(self._autoidcounter)