Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Rename MAX_THREADS to DEFAULT_THREADS to improve clarity and consiste…
…ncy in the Worker thread configuration.
  • Loading branch information
rroblf01 committed Nov 14, 2025
commit fa7ee12f606fef10c0044d74f0ab981e90fce7e1
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
from django_tasks.backends.database.backend import DatabaseBackend
from django_tasks.backends.database.models import DBTaskResult
from django_tasks.backends.database.utils import exclusive_transaction
from django_tasks.base import DEFAULT_TASK_QUEUE_NAME, MAX_THREADS, TaskContext
from django_tasks.base import DEFAULT_TASK_QUEUE_NAME, DEFAULT_THREADS, TaskContext
from django_tasks.exceptions import InvalidTaskBackendError
from django_tasks.signals import task_finished, task_started
from django_tasks.utils import get_random_id
Expand All @@ -40,7 +40,7 @@ def __init__(
startup_delay: bool,
max_tasks: int | None,
worker_id: str,
max_threads: int = MAX_THREADS,
max_threads: int = DEFAULT_THREADS,
):
self.queue_names = queue_names
self.process_all_queues = "*" in queue_names
Expand Down Expand Up @@ -294,9 +294,9 @@ def add_arguments(self, parser: ArgumentParser) -> None:
parser.add_argument(
"--max-threads",
nargs="?",
default=MAX_THREADS,
default=DEFAULT_THREADS,
type=valid_max_tasks,
help=f"The maximum number of threads to use for processing tasks (default: {MAX_THREADS})",
help=f"The maximum number of threads to use for processing tasks (default: {DEFAULT_THREADS})",
)

def configure_logging(self, verbosity: int) -> None:
Expand Down
2 changes: 1 addition & 1 deletion django_tasks/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
TASK_MIN_PRIORITY = -100
TASK_MAX_PRIORITY = 100
TASK_DEFAULT_PRIORITY = 0
MAX_THREADS = 1
DEFAULT_THREADS = 1

TASK_REFRESH_ATTRS = {
"errors",
Expand Down