diff --git a/runtests.py b/runtests.py
index 7ab8948..86f0961 100644
--- a/runtests.py
+++ b/runtests.py
@@ -1,10 +1,7 @@
 #!/usr/bin/env python
-import os
 import sys
 
 if __name__ == "__main__":
-    os.environ['DJANGO_SETTINGS_MODULE'] = 'tests.test_settings'
-    print(os.getcwd())
     try:
         from django.core.management import execute_from_command_line
     except ImportError:
@@ -12,7 +9,7 @@
         # issue is really that Django is missing to avoid masking other
         # exceptions on Python 2.
         try:
-            import django
+            import django  # noqa: F401
         except ImportError:
             raise ImportError(
                 "Couldn't import Django. Are you sure it's installed and "
@@ -20,4 +17,4 @@
                 "forget to activate a virtual environment?"
             )
         raise
-    execute_from_command_line(sys.argv.insert(1, 'test'))
+    execute_from_command_line(sys.argv.insert(1, "test"))
diff --git a/tests/celery.py b/tests/celery.py
index 5b52754..ce2dd32 100644
--- a/tests/celery.py
+++ b/tests/celery.py
@@ -12,6 +12,19 @@
 # Using a string here means the worker don't have to serialize
 # the configuration object to child processes.
 app.config_from_object('django.conf:settings')
+
+# Automatically try to establish the connection to the AMQP broker on
+# Celery startup if it is unavailable.
+app.conf.broker_connection_retry_on_startup = True
+
+# setup priorities ( 0 Highest, 9 Lowest )
+app.conf.broker_transport_options = {
+    'priority_steps': list(range(10)),  # setup que to have 10 steps
+    'queue_order_strategy': 'priority',  # setup que to use prio sorting
+}
+app.conf.task_default_priority = 5  # anything called with the task.delay() will be given normal priority (5)
+app.conf.worker_prefetch_multiplier = 1  # only prefetch single tasks at a time on the workers so that prio tasks happen
+
 app.conf.ONCE = {
     'backend': 'allianceauth.services.tasks.DjangoBackend',
     'settings': {}