Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
from . import database
from . import domains
+from . import util
# Setup logging
log = logging.getLogger(__name__)
threshold = 1024
# If no domains have been passed, fetch some from the database
- if not domains:
+ if domains:
+ domains = util.aiterable(domains)
+ else:
domains = self.get_domains()
with self.executor:
# Setup logging
log = logging.getLogger(__name__)
+async def aiterable(iterable):
+ for item in iterable:
+ yield item
+
class Stopwatch(object):
def __init__(self, task):
self.task = task