jobs: Rename dispatch function

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/src/buildservice/jobs.py b/src/buildservice/jobs.py
index f2f4b8cdf050c29abb69aaad86d2ad2e15e2ae1d..659050a4253855633619c89d5e0af23bf732e6f7 100644 (file)
--- a/src/buildservice/jobs.py
+++ b/src/buildservice/jobs.py
@@ -143,7 +143,7 @@ class Queue(base.Object):
                        builder.supported_arches,
                )
 
-       async def dispatch_jobs(self):
+       async def dispatch(self):
                """
                        Will be called regularly and will dispatch any pending jobs to any
                        available builders
@@ -436,7 +436,7 @@ class Job(base.DataObject):
                        self._set_attribute("aborted_by", user)
 
                # Dispatch more jobs
-               await self.backend.jobs.queue.dispatch_jobs()
+               await self.backend.jobs.queue.dispatch()
 
        def is_aborted(self):
                """

diff --git a/src/web/builders.py b/src/web/builders.py
index af67fe76dd4821f0661375e8487dccdf8bf43af3..0e4cf897f867d8fa76ac4bed130aae09ac47522e 100644 (file)
--- a/src/web/builders.py
+++ b/src/web/builders.py
@@ -15,7 +15,7 @@ class APIv1ControlHandler(base.APIMixin, tornado.websocket.WebSocketHandler):
                self.current_user.connected(self)
 
                # After the builder has connected, try to dispatch some jobs
-               await self.backend.jobs.queue.dispatch_jobs()
+               await self.backend.jobs.queue.dispatch()
 
        def on_ping(self, data):
                log.debug("%s has pinged us" % self.builder)

diff --git a/src/web/builds.py b/src/web/builds.py
index 2c97830be4fd837100a01ac6c9611156e4f72392..ac775400e560151da1857a2996ede2d9f0533073 100644 (file)
--- a/src/web/builds.py
+++ b/src/web/builds.py
@@ -56,7 +56,7 @@ class APIv1IndexHandler(base.APIMixin, base.BaseHandler):
                await self.backend.jobs.depcheck(build.jobs)
 
                # Try to dispatch jobs
-               await self.backend.jobs.queue.dispatch_jobs()
+               await self.backend.jobs.queue.dispatch()
 
 
 class IndexHandler(base.BaseHandler):

diff --git a/src/web/jobs.py b/src/web/jobs.py
index 3e624ea1b1378b7c564fe23804986c371e6ba129..8129f826d9cc0ac37791333c6e500ea861ae94d7 100644 (file)
--- a/src/web/jobs.py
+++ b/src/web/jobs.py
@@ -81,7 +81,7 @@ class APIv1DetailHandler(base.APIMixin, tornado.websocket.WebSocketHandler):
                        await self.job.finished(success=success, logfile=logfile, packages=packages)
 
                # Try to dispatch the next job
-               await self.backend.jobs.queue.dispatch_jobs()
+               await self.backend.jobs.queue.dispatch()
 
 
 class APIv1LogStreamHandler(base.BackendMixin, tornado.websocket.WebSocketHandler):