Use default database for (Partial)UpdateWorkerRun

arkindex/process/api.py

@@ -1488,6 +1488,7 @@ class WorkerRunDetails(ProcessACLMixin, RetrieveUpdateDestroyAPIView):
             )
 
         queryset = WorkerRun.objects \
+            .using("default") \
             .filter(run_filters) \
             .select_related("process__corpus") \
             .annotate(process_has_tasks=Exists(Task.objects.filter(process=OuterRef("process_id"))))

arkindex/process/serializers/worker_runs.py

@@ -210,7 +210,16 @@ class WorkerRunSerializer(serializers.ModelSerializer):
             if worker_version.model_usage == FeatureUsage.Disabled:
                 errors["model_version_id"].append("This worker version does not support models.")
 
-        existing_worker_run = self._process.worker_runs.filter(version=worker_version, model_version_id=model_version, configuration=configuration)
+        existing_worker_run = (
+            self._process
+            .worker_runs
+            .using("default")
+            .filter(
+                version=worker_version,
+                model_version_id=model_version,
+                configuration=configuration,
+            )
+        )
         if self.instance:
             # The current worker run cannot be a duplicate of itself!
             existing_worker_run = existing_worker_run.exclude(id=self.instance.id)