Run linters

Author: AlanCoding

ansible_base/task/management/commands/run_dispatcher.py

@@ -1,5 +1,4 @@
 from dispatcher.main import DispatcherMain
-
 from django.core.management.base import BaseCommand
 
 
@@ -12,9 +11,7 @@ def handle(self, *args, **options):
                 "brokers": {
                     "pg_notify": {"conninfo": settings.PG_NOTIFY_DSN_SERVER},
                     # TODO: sanitize or escape channel names on dispatcher side
-                    "channels": [
-                        "dab_broadcast"
-                    ],
+                    "channels": ["dab_broadcast"],
                 },
                 # NOTE: I would prefer to move the activation monitoring
                 # from worker to activation, but that is more work
@@ -23,4 +20,4 @@ def handle(self, *args, **options):
             "pool": {"max_workers": 4},
         }
 
-        DispatcherMain()
+        DispatcherMain()

ansible_base/task/models.py

@@ -1,9 +1,9 @@
-from uuid import uuid4
 from types import SimpleNamespace
+from uuid import uuid4
 
 from django.db import models
-from django.utils.translation import gettext_lazy as _
 from django.utils.timezone import now
+from django.utils.translation import gettext_lazy as _
 
 # NOTE: tasks are not registered in the database, but in a dispatcher registry
 
@@ -23,32 +23,21 @@ class Task(models.Model):
     Corresponds to a call of a task, as a higher-level abstraction around the dispatcher.
     Loosely modeled after pulpcore.Task
     """
-    uuid = models.UUIDField(
-        primary_key=True, default=uuid4, editable=False,
-        help_text=_('UUID that corresponds to the dispatcher task uuid')
-    )
+
+    uuid = models.UUIDField(primary_key=True, default=uuid4, editable=False, help_text=_('UUID that corresponds to the dispatcher task uuid'))
     state = models.CharField(
         choices=[(s, s.title()) for s in sorted(vars(TASK_STATES).values())],
         default=TASK_STATES.WAITING,
-        help_text=_('Choices of this field track with acknowledgement and completion of a task')
-    )
-    name = models.TextField(
-        help_text=_('Importable path for class or method')
+        help_text=_('Choices of this field track with acknowledgement and completion of a task'),
     )
+    name = models.TextField(help_text=_('Importable path for class or method'))
 
     created = models.DateTimeField(
-        auto_now_add=True,
-        help_text=_('Time the publisher (submitter) of this task call created it, approximately the time of submission as well')
+        auto_now_add=True, help_text=_('Time the publisher (submitter) of this task call created it, approximately the time of submission as well')
     )
     # pulp has unblocking logic, like unblocked_at, we have no plans for that here
-    started_at = models.DateTimeField(
-        null=True,
-        help_text=_('Time of acknowledgement, also approximately the time the task starts')
-    )
-    finished_at = models.DateTimeField(
-        null=True,
-        help_text=_('Time task is cleared (whether failed or succeeded), may be unused if set to auto-delete')
-    )
+    started_at = models.DateTimeField(null=True, help_text=_('Time of acknowledgement, also approximately the time the task starts'))
+    finished_at = models.DateTimeField(null=True, help_text=_('Time task is cleared (whether failed or succeeded), may be unused if set to auto-delete'))
 
     def mark_ack(self):
         self.state = TASK_STATES.RUNNING

ansible_base/task/publish.py

@@ -1,12 +1,12 @@
-from django.db import transaction
-
 from dispatcher.utils import serialize_task
+from django.db import transaction
 
-from ansible_base.task.tasks import run_task_from_queue
 from ansible_base.task.models import Task
+from ansible_base.task.tasks import run_task_from_queue
 
 # decorator structure is taken from dispatcher.publish
 
+
 class TaskPublisher:
     def __init__(self, fn):
         self.fn = fn

ansible_base/task/tasks.py

@@ -1,11 +1,10 @@
 import logging
 
-from ansible_base.task.models import Task, TASK_STATES
-
 from dispatcher.utils import resolve_callable
-
 from django.db import transaction
 
+from ansible_base.task.models import TASK_STATES, Task
+
 logger = logging.getLogger(__name__)