From: Michael Tremer Date: Thu, 13 Oct 2022 15:04:17 +0000 (+0000) Subject: jobs: Rename start() to assign() X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=296b4e021a59eaae81ba6a52b3d5a96c62bcc366;p=pbs.git jobs: Rename start() to assign() This is more like what this function does Signed-off-by: Michael Tremer --- diff --git a/src/buildservice/jobs.py b/src/buildservice/jobs.py index f11914da..e97c97da 100644 --- a/src/buildservice/jobs.py +++ b/src/buildservice/jobs.py @@ -218,9 +218,9 @@ class Job(base.DataObject): """ return self.data.finished_at - def start(self, builder): + def assign(self, builder): """ - Starts this job on builder + Assigns this job to a builder """ log.info("Starting job %s on %s" % (self, builder)) diff --git a/src/hub/queue.py b/src/hub/queue.py index 8310d113..6873e490 100644 --- a/src/hub/queue.py +++ b/src/hub/queue.py @@ -114,9 +114,9 @@ class QueueHandler(BackendMixin, tornado.websocket.WebSocketHandler): def assign_job(self, job): logging.debug("Sending job %s to %s" % (job, self)) - # Start this job + # Assign this job with self.db.transaction(): - job.start(builder=self.builder) + job.assign(builder=self.builder) self.write_message({ "message" : "job",