diff options
Diffstat (limited to 'thread_utils.py')
| -rw-r--r-- | thread_utils.py | 8 |
1 files changed, 2 insertions, 6 deletions
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) |