The test

Author: mgax

tests/tests/test_database_backend.py

@@ -26,6 +26,7 @@
 
 from django_tasks import ResultStatus, Task, default_task_backend, tasks
 from django_tasks.backends.database import DatabaseBackend
+from django_tasks.backends.database.backend import TaskResult
 from django_tasks.backends.database.management.commands.prune_db_task_results import (
     logger as prune_db_tasks_logger,
 )
@@ -953,6 +954,28 @@ def test_get_locked_with_locked_rows(self) -> None:
         finally:
             new_connection.close()
 
+    def test_duplicate(self) -> None:
+        result_1 = cast(TaskResult, test_tasks.calculate_meaning_of_life.enqueue())
+        db_result_1 = result_1.db_result
+        db_result_2 = result_1.db_result.duplicate()
+        db_result_2.save()
+        result_2 = db_result_2.task_result
+
+        assert db_result_1.pk != db_result_2.pk
+
+        call_command(
+            "db_worker",
+            verbosity=0,
+            batch=True,
+            interval=0,
+            startup_delay=False,
+        )
+
+        result_1.refresh()
+        result_2.refresh()
+
+        assert result_1.return_value == result_2.return_value
+
 
 class ConnectionExclusiveTranscationTestCase(TestCase):
     def setUp(self) -> None: