jobs: Update message to abort

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

diff --git a/src/buildservice/jobs.py b/src/buildservice/jobs.py
index f5fd608b80232eba008eb164c81cd5d0c597fbce..ce5dc1f30c83d5652e27d24e2a3cf23e25123f10 100644 (file)
--- a/src/buildservice/jobs.py
+++ b/src/buildservice/jobs.py
@@ -849,11 +849,13 @@ class Job(database.Base, database.BackendMixin, database.SoftDeleteMixin):
                        Aborts the job
                """
                # Tell the builder to abort the job
-               if self.connection:
-                       await self.connection.write_message({
-                               "type" : "abort",
-                               "data" : {},
+               try:
+                       await self.builder.send_message({
+                               "job_id"  : "%s" % self.uuid,
+                               "command" : "abort",
                        })
+               except builders.BuilderNotOnlineError as e:
+                       pass
 
                # Mark as finished
                self.finished_at = sqlalchemy.func.current_timestamp()