From 9626c0820190c86a2e70e06ed41e0fb95913d9d3 Mon Sep 17 00:00:00 2001 From: dbth <1097224+believethehype@users.noreply.github.com> Date: Thu, 2 Jan 2025 21:09:18 +0100 Subject: [PATCH] Update dvmtaskinterface.py --- nostr_dvm/interfaces/dvmtaskinterface.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/nostr_dvm/interfaces/dvmtaskinterface.py b/nostr_dvm/interfaces/dvmtaskinterface.py index db4c231..2e50b9b 100644 --- a/nostr_dvm/interfaces/dvmtaskinterface.py +++ b/nostr_dvm/interfaces/dvmtaskinterface.py @@ -38,7 +38,7 @@ class DVMTaskInterface: def __init__(self, name, dvm_config: DVMConfig, nip89config: NIP89Config, nip88config: NIP88Config = None, admin_config: AdminConfig = None, options=None, task=None): - self.stop_threads = False + self.stop_thread = False self.nostr_dvm_thread = None if options is None: self.options = {} @@ -112,17 +112,17 @@ class DVMTaskInterface: pass def run(self): - stop_threads = False + self.stop_thread = False try: - self.nostr_dvm_thread = Thread(target=self.DVM, args=[self.dvm_config, self.admin_config, lambda: stop_threads], daemon=False) + self.nostr_dvm_thread = Thread(target=self.DVM, args=[self.dvm_config, self.admin_config, lambda: self.stop_thread], daemon=False) self.nostr_dvm_thread.start() except BaseException as e: print("gone") def join(self): - self.stop_threads = True + self.stop_thread = True self.nostr_dvm_thread.join(1) dvm_shutdown(self.dvm_config)