diff --git a/tests/backends/test_base.py b/tests/backends/test_base.py index 950e08a..8f71e0a 100644 --- a/tests/backends/test_base.py +++ b/tests/backends/test_base.py @@ -35,7 +35,7 @@ class BackendDouble(ThreadmillTaskBackend): def enqueue(self, task, args, kwargs): return TaskResult( task=task, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TaskResultStatus.READY, enqueued_at=timezone.now(), started_at=None, @@ -132,7 +132,7 @@ def test_serialize_task_result__omits_retry_when_none(self) -> None: task = RetryTask(func=echo.func) result = TaskResult( task=task, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TRS.READY, enqueued_at=tz.now(), started_at=None, @@ -321,7 +321,7 @@ def _task_result_with_retry(task, *, errors=None, worker_ids=None) -> TaskResult now = tz.now() return TaskResult( task=task, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TRS.FAILED, enqueued_at=now, started_at=now, diff --git a/tests/test_executor.py b/tests/test_executor.py index 456e376..85022a4 100644 --- a/tests/test_executor.py +++ b/tests/test_executor.py @@ -47,7 +47,7 @@ def _task_result(task, *args, **kwargs) -> TaskResult: """Build a READY `TaskResult` without touching Redis.""" return TaskResult( task=task, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TaskResultStatus.READY, enqueued_at=timezone.now(), started_at=None, diff --git a/tests/test_retry.py b/tests/test_retry.py index ada3aff..40a9aaf 100644 --- a/tests/test_retry.py +++ b/tests/test_retry.py @@ -12,7 +12,7 @@ def _context(*, attempt: int, exception_class: type[Exception]) -> TaskContext: """Build a TaskContext with a single error of the given exception class.""" result = TaskResult( task=print, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TaskResultStatus.FAILED, enqueued_at=timezone.now(), started_at=timezone.now(), @@ -132,7 +132,7 @@ def test_serialize__roundtrips_through_task_result(self) -> None: task = RetryTask(func=echo.func, retry=backoff) result = TaskResult( task=task, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TaskResultStatus.FAILED, enqueued_at=timezone.now(), started_at=timezone.now(), diff --git a/tests/testapp/tasks.py b/tests/testapp/tasks.py index 0be41ac..ce8b57a 100644 --- a/tests/testapp/tasks.py +++ b/tests/testapp/tasks.py @@ -59,7 +59,7 @@ async def io_workload(): @task(queue_name="memory") def memory_workload(): """Allocate and leak 100MB of memory.""" - leak[uuid.uuid4()] = "x" * 1024 * 1024 * 100 + leak[uuid.uuid7()] = "x" * 1024 * 1024 * 100 @task() diff --git a/threadmill/backends/redis.py b/threadmill/backends/redis.py index f67989b..8c1a12e 100644 --- a/threadmill/backends/redis.py +++ b/threadmill/backends/redis.py @@ -190,7 +190,7 @@ def enqueue( enqueued_at = timezone.now() task_result = TaskResult( task=task, - id=str(uuid.uuid4()), + id=str(uuid.uuid7()), status=TaskResultStatus.READY, enqueued_at=enqueued_at, started_at=None,