highperfocused/nostrdvm
1
0
Fork 0
mirror of https://github.com/believethehype/nostrdvm.git synced 2025-06-25 20:20:53 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update dvmtaskinterface.py

Browse Source
This commit is contained in:
dbth 2025-01-02 21:09:18 +01:00
parent 47c842fa90
commit 9626c08201
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
nostr_dvm/interfaces/dvmtaskinterface.py
View File

@ -38,7 +38,7 @@ class DVMTaskInterface:
def __init__(self, name, dvm_config: DVMConfig, nip89config: NIP89Config, nip88config: NIP88Config = None, def __init__(self, name, dvm_config: DVMConfig, nip89config: NIP89Config, nip88config: NIP88Config = None,
admin_config: AdminConfig = None, admin_config: AdminConfig = None,
options=None, task=None): options=None, task=None):
self.stop_threads = False self.stop_thread = False
self.nostr_dvm_thread = None self.nostr_dvm_thread = None
if options is None: if options is None:
self.options = {} self.options = {}
@ -112,17 +112,17 @@ class DVMTaskInterface:
pass pass
def run(self): def run(self):
stop_threads = False self.stop_thread = False
try: 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() self.nostr_dvm_thread.start()
except BaseException as e: except BaseException as e:
print("gone") print("gone")
def join(self): def join(self):
self.stop_threads = True self.stop_thread = True
self.nostr_dvm_thread.join(1) self.nostr_dvm_thread.join(1)
dvm_shutdown(self.dvm_config) dvm_shutdown(self.dvm_config)