2020-08-11 09:43:03 +00:00
|
|
|
# MIT licensed
|
|
|
|
|
# Copyright (c) 2020 lilydjwg <lilydjwg@gmail.com>, et al.
|
|
|
|
|
|
|
|
|
|
from __future__ import annotations
|
|
|
|
|
|
2020-08-14 12:04:05 +00:00
|
|
|
from nvchecker.api import (
|
|
|
|
|
BaseWorker, GetVersionError, RawResult,
|
|
|
|
|
)
|
2020-08-11 09:43:03 +00:00
|
|
|
|
|
|
|
|
class Worker(BaseWorker):
|
|
|
|
|
async def run(self) -> None:
|
2020-08-14 12:04:05 +00:00
|
|
|
exc = GetVersionError('no source specified')
|
2020-09-20 14:15:54 +00:00
|
|
|
async with self.task_sem:
|
2020-08-14 12:04:05 +00:00
|
|
|
for name, conf in self.tasks:
|
2020-08-17 07:11:14 +00:00
|
|
|
await self.result_q.put(
|
2020-08-14 12:04:05 +00:00
|
|
|
RawResult(name, exc, conf))
|
