code formating

Author: Dorian Birraux

wolframclient/evaluation/kernel/kernelcontroller.py

@@ -507,7 +507,9 @@ def _new_running_event(self):
         Create a new event that triggers when the kernel process has terminated or when termination was requested.
         :return:
         """
-        return _ProcessAliveNotAbortedEvent(self.kernel_proc, self.trigger_termination_requested)
+        return _ProcessAliveNotAbortedEvent(
+            self.kernel_proc, self.trigger_termination_requested
+        )
 
     def _recv_check_process(self, copy=False):
         """
@@ -517,7 +519,9 @@ def _recv_check_process(self, copy=False):
         :return:
         """
         try:
-            return self.kernel_socket_in.recv_abortable(copy=copy, abort_event=self._new_running_event())
+            return self.kernel_socket_in.recv_abortable(
+                copy=copy, abort_event=self._new_running_event()
+            )
         except SocketAborted:
             logger.info("Kernel process is not running anymore.")
             raise WolframKernelException("Kernel is not running anymore.")
@@ -638,9 +642,10 @@ def __init__(self, subprocess, abort_event):
     def is_set(self):
         return self.subprocess.poll() is not None or self.abort_event.is_set()
 
+
 class _KernelProcessDied(object):
     def __init__(self, subprocess):
         self.subprocess = subprocess
 
     def is_set(self):
-        return self.subprocess.poll() is not None
+        return self.subprocess.poll() is not None

wolframclient/tests/evaluation/test_coroutine.py

@@ -2,14 +2,14 @@
 
 import logging
 
-from wolframclient.exception import WolframKernelException
 from wolframclient.deserializers import WXFConsumer, binary_deserialize
 from wolframclient.evaluation import (
     WolframCloudAsyncSession,
     WolframEvaluatorPool,
     WolframLanguageAsyncSession,
     parallel_evaluate,
 )
+from wolframclient.exception import WolframKernelException
 from wolframclient.language import wl, wlexpr
 from wolframclient.tests.configure import (
     kernel_path,

wolframclient/tests/evaluation/test_kernel.py

@@ -199,7 +199,7 @@ def test_kernel_abort_restart(self):
         try:
             session = WolframLanguageSession(kernel_path)
             session.start()
-            start=time()
+            start = time()
             future = session.evaluate_future("Pause[10]")
             with self.assertRaises(TimeoutError):
                 future.result(timeout=1.0)

wolframclient/tests/externalevaluate/ev_loop.py

@@ -9,6 +9,7 @@
 from wolframclient.utils.externalevaluate import EXPORT_KWARGS, start_zmq_loop
 from wolframclient.utils.tests import TestCase as BaseTestCase
 
+
 class TestCase(BaseTestCase):
     def compare(self, string_version, result):
         self.assertEqual(string_version, export(result, **EXPORT_KWARGS))