sq-poller: varius fixes on Node log messages

Signed-off-by: Claudio Lorina <[email protected]>

Author: claudiolor

suzieq/poller/worker/nodes/node.py

@@ -146,8 +146,7 @@ async def initialize(self, **kwargs) -> TNode:
                                                           passphrase)
                 if not self.jump_host_key:
                     raise SqPollerConfError('Unable to read private key file'
-                                            f' at {pvtkey_file}'
-                                            )
+                                            f' at {pvtkey_file}')
         else:
             self.jump_host = None
             self.jump_host_key = None
@@ -849,7 +848,6 @@ async def _exec_cmd(self, service_callback, cmd_list, cb_token,
         if only_one is True, commands are executed until the first one that
         succeeds, and the rest are ignored.
         '''
-
         if self.transport == "ssh":
             await self._ssh_gather(service_callback, cmd_list, cb_token,
                                    oformat, timeout, only_one)
@@ -1229,7 +1227,7 @@ async def _rest_gather(self, service_callback, cmd_list, cb_token,
                     result.append(self._create_error(cmd))
                 self.logger.error(
                     f"{self.transport}://{self.hostname}:{self.port}: Unable "
-                    "to communicate with node due to str(e)")
+                    f"to communicate with node due to {str(e)}")
 
         await service_callback(result, cb_token)
 
@@ -1340,8 +1338,8 @@ async def _init_rest(self):
             except Exception as e:
                 self.current_exception = e
                 self.logger.error(
-                    "{self.transport}://{self.hostname}:{self.port}: Unable to"
-                    " communicate with node due to {str(e)}")
+                    f"{self.transport}://{self.hostname}:{self.port}: Unable "
+                    f"to communicate with node due to {str(e)}")
 
     async def _rest_gather(self, service_callback, cmd_list, cb_token,
                            oformat='json', timeout=None):
@@ -1381,8 +1379,8 @@ async def _rest_gather(self, service_callback, cmd_list, cb_token,
                 self.current_exception = e
                 result.append(self._create_error(cmd_list))
                 self.logger.error(
-                    "{self.transport}://{self.hostname}:{self.port}: Unable "
-                    "to communicate with node due to {str(e)}")
+                    f"{self.transport}://{self.hostname}:{self.port}: Unable "
+                    f"to communicate with node due to {str(e)}")
 
         await service_callback(result, cb_token)
 
@@ -1709,10 +1707,10 @@ async def _ssh_gather(self, service_callback, cmd_list, cb_token, oformat,
                             await self._close_connection()
                             self.logger.debug("Closed conn successfully for "
                                               f"{self.hostname}")
-                        except Exception as e1:
+                        except Exception as close_exc:
                             self.logger.error(
                                 f"Caught an exception closing {self.hostname}"
-                                f" for {cmd}: {e1}")
+                                f" for {cmd}: {close_exc}")
                     else:
                         self.logger.error(
                             f"Unable to connect to {self.hostname} {cmd} "