X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=thread_utils.py;h=d8c85f46fbcaed33864d591458c64a1cebeb162d;hb=bddea36b81ea326fccfa27ef0bae2a80ba1041fd;hp=ad1f0bf9029b3232ba9cbd28b085afade91f0186;hpb=36fea7f15ed17150691b5b3ead75450e575229ef;p=python_utils.git

diff --git a/thread_utils.py b/thread_utils.py
index ad1f0bf..d8c85f4 100644
--- a/thread_utils.py
+++ b/thread_utils.py
@@ -61,9 +61,7 @@ def background_thread(
 
     def wrapper(funct: Callable):
         @functools.wraps(funct)
-        def inner_wrapper(
-            *a, **kwa
-        ) -> Tuple[threading.Thread, threading.Event]:
+        def inner_wrapper(*a, **kwa) -> Tuple[threading.Thread, threading.Event]:
             should_terminate = threading.Event()
             should_terminate.clear()
             newargs = (*a, should_terminate)
@@ -130,9 +128,7 @@ def periodically_invoke(
             should_terminate = threading.Event()
             should_terminate.clear()
             newargs = (should_terminate, *args)
-            thread = threading.Thread(
-                target=helper_thread, args=newargs, kwargs=kwargs
-            )
+            thread = threading.Thread(target=helper_thread, args=newargs, kwargs=kwargs)
             thread.start()
             logger.debug(f'Started thread {thread.name} tid={thread.ident}')
             return (thread, should_terminate)