fix lint issues

taskq/migrations/0001_initial.py

@@ -4,7 +4,6 @@
 
 
 class Migration(migrations.Migration):
-
     initial = True
 
     dependencies = []

taskq/migrations/0002_add_retry_delay.py

@@ -6,7 +6,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0001_initial")]
 
     operations = [

taskq/migrations/0003_make_retry_delay_nonnullable.py

@@ -7,7 +7,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0002_add_retry_delay")]
 
     operations = [

taskq/migrations/0004_modify_max_retries_default.py

@@ -6,7 +6,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0003_make_retry_delay_nonnullable")]
 
     operations = [

taskq/migrations/0005_fix_model_fields_types.py

@@ -7,7 +7,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0004_modify_max_retries_default")]
 
     operations = [

taskq/migrations/0006_auto_20190705_0601.py

@@ -6,7 +6,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0005_fix_model_fields_types")]
 
     operations = [

taskq/migrations/0007_task_timeout.py

@@ -4,7 +4,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0006_auto_20190705_0601")]
 
     operations = [

taskq/migrations/0008_alter_task_status.py

@@ -4,7 +4,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [("taskq", "0007_task_timeout")]
 
     operations = [

taskq/migrations/0009_use_jsonfield_for_function_args.py

@@ -5,15 +5,18 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [
-        ('taskq', '0008_alter_task_status'),
+        ("taskq", "0008_alter_task_status"),
     ]
 
     operations = [
         migrations.AlterField(
-            model_name='task',
-            name='function_args',
-            field=models.JSONField(decoder=taskq.json.JSONDecoder, default=dict, encoder=taskq.json.JSONEncoder),
+            model_name="task",
+            name="function_args",
+            field=models.JSONField(
+                decoder=taskq.json.JSONDecoder,
+                default=dict,
+                encoder=taskq.json.JSONEncoder,
+            ),
         ),
     ]

taskq/task.py

@@ -32,18 +32,18 @@ def apply_async(
         kwargs=None,
     ):
         """Apply a task asynchronously.
-.
-        :param Tuple args: The positional arguments to pass on to the task.
+        .
+                :param Tuple args: The positional arguments to pass on to the task.
 
-        :parm Dict kwargs: The keyword arguments to pass on to the task.
+                :parm Dict kwargs: The keyword arguments to pass on to the task.
 
-        :parm due_at: When the task should be executed. (None = now).
-        :type due_at: timedelta or None
+                :parm due_at: When the task should be executed. (None = now).
+                :type due_at: timedelta or None
 
-        :param timeout: The maximum time a task may run.
-                        (None = no timeout)
-                        (int = number of seconds)
-        :type timeout: timedelta or int or None
+                :param timeout: The maximum time a task may run.
+                                (None = no timeout)
+                                (int = number of seconds)
+                :type timeout: timedelta or int or None
         """
 
         if due_at is None:

tests/test_consumer.py

@@ -129,7 +129,6 @@ def test_consumer_db_error(self):
         tasks = [create_task() for _ in range(task_count)]
 
         with self.assertLogs("taskq", level="ERROR") as taskq_error_logger_check:
-
             with patch.object(Task, "save", autospec=True) as mock_task_save:
                 running_tasks = set()
                 error_task = None
@@ -280,8 +279,7 @@ def test_consumer_taskq_fetched_tasks_count_logging_threshold_counter_reset(self
         }
     )
     def test_consumer_create_task_for_due_scheduled_task(self):
-        """Consumer creates tasks for each scheduled task defined in settings.
-        """
+        """Consumer creates tasks for each scheduled task defined in settings."""
         consumer = Consumer()
 
         # Hack the due_at date to simulate the fact that the task was run once

tests/test_consumer_multiprocess.py

@@ -15,7 +15,6 @@
 
 
 class ConsumerMultiProcessTestCase(TransactionTestCase):
-
     # To run these tests, create_background_consumers uses threads.
     # This is not compatible with current timeout implementation based on signals.
     # Hence we force timeout at 0.