From 0f4f10d2d83eab44e23a068be84aa59caaf1d308 Mon Sep 17 00:00:00 2001 From: schneefux Date: Mon, 13 Mar 2017 21:13:36 +0100 Subject: use joblib notifications --- api.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'api.py') diff --git a/api.py b/api.py index 935991d..0d7875a 100644 --- a/api.py +++ b/api.py @@ -82,12 +82,12 @@ class Processor(joblib.worker.Worker): await self._srctr.commit() await self._desttr.commit() - await self._queue.request( + await self.request( jobtype="compile", payload=self._compilejobs, priority=self._priorities) if self._do_analyze: - await self._queue.request( + await self.request( jobtype="analyze", payload=self._analyzejobs) @@ -100,7 +100,7 @@ class Processor(joblib.worker.Worker): "filter[gameMode]": "casual,ranked" } } for s in self._preloads] - await self._queue.request( + await self.request( jobtype="preload", payload=preloadjobs, priority=[2]*len(preloadjobs)) -- cgit v1.3.1