Update black code style

Author: codingjoe

joeflow/forms.py

@@ -6,7 +6,9 @@
 
 class OverrideForm(forms.ModelForm):
     next_tasks = forms.MultipleChoiceField(
-        label=t("Next tasks"), choices=[], required=False,
+        label=t("Next tasks"),
+        choices=[],
+        required=False,
     )
 
     def __init__(self, *args, **kwargs):
@@ -32,7 +34,8 @@ def start_next_tasks(self, user=None):
             except models.Task.DoesNotExist:
                 parent_tasks = []
         override_task = self.instance.task_set.create(
-            name="override", type=models.Task.HUMAN,
+            name="override",
+            type=models.Task.HUMAN,
         )
         override_task.parent_task_set.set(parent_tasks)
         override_task.finish(user=user)

joeflow/models.py

@@ -368,14 +368,19 @@ def cancel(self, user=None):
         if user and not user.is_authenticated:
             user = None
         return self.update(
-            status=self.model.CANCELED, completed_by_user=user, completed=Now(),
+            status=self.model.CANCELED,
+            completed_by_user=user,
+            completed=Now(),
         )
 
 
 class Task(models.Model):
     id = models.BigAutoField(primary_key=True, editable=False)
     _workflow = models.ForeignKey(
-        Workflow, on_delete=models.CASCADE, db_column="workflow_id", editable=False,
+        Workflow,
+        on_delete=models.CASCADE,
+        db_column="workflow_id",
+        editable=False,
     )
     content_type = models.ForeignKey(
         "contenttypes.ContentType",
@@ -397,11 +402,17 @@ class Task(models.Model):
         (MACHINE, t(MACHINE)),
     )
     type = models.CharField(
-        max_length=50, choices=_type_choices, editable=False, db_index=True,
+        max_length=50,
+        choices=_type_choices,
+        editable=False,
+        db_index=True,
     )
 
     parent_task_set = models.ManyToManyField(
-        "self", related_name="child_task_set", editable=False, symmetrical=False,
+        "self",
+        related_name="child_task_set",
+        editable=False,
+        symmetrical=False,
     )
 
     FAILED = "failed"

joeflow/runner/dramatiq.py

@@ -13,7 +13,9 @@
 def task_runner(*, task_pk, workflow_pk, countdown=None, eta=None, retries=0):
     """Schedule asynchronous machine task using celery."""
     _dramatiq_task_runner.send_with_options(
-        args=(task_pk, workflow_pk), delay=countdown, retries=retries,
+        args=(task_pk, workflow_pk),
+        delay=countdown,
+        retries=retries,
     )
 
 

joeflow/tasks/machine.py

@@ -110,7 +110,9 @@ def __call__(self, workflow, task):
 
     def create_task(self, workflow):
         return workflow.task_set.get_or_create(
-            name=self.name, type=self.type, completed=None,
+            name=self.name,
+            type=self.type,
+            completed=None,
         )[0]
 
 

joeflow/views.py

@@ -14,7 +14,11 @@ class WorkflowTemplateNameViewMixin:
     def get_template_names(self):
         names = [
             "%s/%s_%s.html"
-            % (self.model._meta.app_label, self.model._meta.model_name, self.name,)
+            % (
+                self.model._meta.app_label,
+                self.model._meta.model_name,
+                self.name,
+            )
         ]
         names.extend(super().get_template_names())
         names.append(
@@ -44,7 +48,10 @@ def __init__(self, **kwargs):
     def get_task(self):
         try:
             return get_object_or_404(
-                models.Task, pk=self.kwargs["pk"], name=self.name, completed=None,
+                models.Task,
+                pk=self.kwargs["pk"],
+                name=self.name,
+                completed=None,
             )
         except KeyError:
             return models.Task(name=self.name, type=models.Task.HUMAN)

tests/testapp/models.py

@@ -12,7 +12,10 @@ class Shipment(Workflow):
 
 class WelcomeWorkflowState(Workflow):
     user = models.ForeignKey(
-        settings.AUTH_USER_MODEL, on_delete=models.CASCADE, blank=True, null=True,
+        settings.AUTH_USER_MODEL,
+        on_delete=models.CASCADE,
+        blank=True,
+        null=True,
     )
 
 

tests/testapp/workflows.py

@@ -50,7 +50,8 @@ def has_user(self):
 
     def send_welcome_email(self):
         self.user.email_user(
-            subject="Welcome", message="Hello %s!" % self.user.get_short_name(),
+            subject="Welcome",
+            message="Hello %s!" % self.user.get_short_name(),
         )
 
     def end(self):