From 0b80f7f5032fe7b7169b0b1b2db876e3521736f3 Mon Sep 17 00:00:00 2001 From: Guillermo Rodriguez Date: Mon, 3 Feb 2025 18:43:42 -0300 Subject: [PATCH] Rename my_results --- skynet/dgpu/daemon.py | 8 +++----- skynet/dgpu/network.py | 8 ++++---- 2 files changed, 7 insertions(+), 9 deletions(-) diff --git a/skynet/dgpu/daemon.py b/skynet/dgpu/daemon.py index a709d0b..d874e37 100755 --- a/skynet/dgpu/daemon.py +++ b/skynet/dgpu/daemon.py @@ -71,9 +71,7 @@ class WorkerDaemon: self._snap = { 'queue': [], 'requests': {}, - 'my_results': [] - # ^and here i thot they were **my** results.. - # :sadcat: + 'results': [] } self._benchmark: list[float] = [] @@ -178,9 +176,9 @@ class WorkerDaemon: if model in self.model_blacklist: return False - my_results = [res['id'] for res in self._snap['my_results']] + results = [res['id'] for res in self._snap['results']] if ( - rid not in my_results + rid not in results and rid in self._snap['requests'] ): diff --git a/skynet/dgpu/network.py b/skynet/dgpu/network.py index 19d78f5..0f95b65 100755 --- a/skynet/dgpu/network.py +++ b/skynet/dgpu/network.py @@ -150,7 +150,7 @@ class NetConnector: async def get_full_queue_snapshot(self): snap = { 'requests': {}, - 'my_results': [] + 'results': [] } snap['queue'] = await self.get_work_requests_last_hour() @@ -159,7 +159,7 @@ class NetConnector: d[key] = await fn(*args, **kwargs) async with trio.open_nursery() as n: - n.start_soon(_run_and_save, snap, 'my_results', self.find_my_results) + n.start_soon(_run_and_save, snap, 'results', self.find_results) for req in snap['queue']: n.start_soon( _run_and_save, snap['requests'], req['id'], self.get_status_by_request_id, req['id']) @@ -227,8 +227,8 @@ class NetConnector: ) ) - async def find_my_results(self): - logging.info('find_my_results') + async def find_results(self): + logging.info('find_results') return await failable( partial( self.cleos.aget_table,