Merge branch 'develop' into 'fb-optic-1178/memory-leak'

Workflow run: https://github.com/HumanSignal/label-studio/actions/runs/12356998670

label_studio/core/all_urls.json

@@ -149,6 +149,12 @@
         "name": "projects:api:project-detail",
         "decorators": ""
     },
+    {
+        "url": "/api/projects/counts/",
+        "module": "projects.api.ProjectCountsListAPI",
+        "name": "projects:api:project-counts-list",
+        "decorators": ""
+    },
     {
         "url": "/api/projects/<int:pk>/next/",
         "module": "projects.api.ProjectNextTaskAPI",

label_studio/feature_flags.json

@@ -2418,6 +2418,33 @@
       "version": 4,
       "deleted": false
     },
+    "fflag_feat_front_dia_1747_projects_list_banner": {
+      "key": "fflag_feat_front_dia_1747_projects_list_banner",
+      "on": false,
+      "prerequisites": [],
+      "targets": [],
+      "contextTargets": [],
+      "rules": [],
+      "fallthrough": {
+        "variation": 0
+      },
+      "offVariation": 1,
+      "variations": [
+        true,
+        false
+      ],
+      "clientSideAvailability": {
+        "usingMobileKey": false,
+        "usingEnvironmentId": false
+      },
+      "clientSide": false,
+      "salt": "21bfa474c82b4ab0b89314fbecd164cc",
+      "trackEvents": false,
+      "trackEventsFallthrough": false,
+      "debugEventsUntilDate": null,
+      "version": 3,
+      "deleted": false
+    },
     "fflag_feat_front_dia_916_model_creation_and_versioning_short": {
       "key": "fflag_feat_front_dia_916_model_creation_and_versioning_short",
       "on": true,
@@ -3036,7 +3063,7 @@
       "trackEvents": false,
       "trackEventsFallthrough": false,
       "debugEventsUntilDate": null,
-      "version": 2,
+      "version": 3,
       "deleted": false
     },
     "fflag_feat_front_optic_1419_backend_csv_comments_export_short": {
@@ -4778,7 +4805,7 @@
       "trackEvents": false,
       "trackEventsFallthrough": false,
       "debugEventsUntilDate": null,
-      "version": 2,
+      "version": 3,
       "deleted": false
     },
     "fflag_fix_leap_246_multi_object_hotkeys_160124_short": {

label_studio/projects/api.py

@@ -29,6 +29,7 @@
 from projects.models import Project, ProjectImport, ProjectManager, ProjectReimport, ProjectSummary
 from projects.serializers import (
     GetFieldsSerializer,
+    ProjectCountsSerializer,
     ProjectImportSerializer,
     ProjectLabelConfigSerializer,
     ProjectModelVersionExtendedSerializer,
@@ -281,6 +282,36 @@ def post(self, request, *args, **kwargs):
         return super(ProjectListAPI, self).post(request, *args, **kwargs)
 
 
+@method_decorator(
+    name='get',
+    decorator=swagger_auto_schema(
+        tags=['Projects'],
+        x_fern_sdk_group_name='projects',
+        x_fern_sdk_method_name='counts',
+        x_fern_audiences=['public'],
+        x_fern_pagination={
+            'offset': '$request.page',
+            'results': '$response.results',
+        },
+        operation_summary="List project's counts",
+        operation_description='Returns a list of projects with their counts. For example, task_number which is the total task number in project',
+    ),
+)
+class ProjectCountsListAPI(generics.ListAPIView):
+    serializer_class = ProjectCountsSerializer
+    filterset_class = ProjectFilterSet
+    permission_required = ViewClassPermission(
+        GET=all_permissions.projects_view,
+    )
+    pagination_class = ProjectListPagination
+
+    def get_queryset(self):
+        serializer = GetFieldsSerializer(data=self.request.query_params)
+        serializer.is_valid(raise_exception=True)
+        fields = serializer.validated_data.get('include')
+        return Project.objects.with_counts(fields=fields).filter(organization=self.request.user.active_organization)
+
+
 @method_decorator(
     name='get',
     decorator=swagger_auto_schema(

label_studio/projects/serializers.py

@@ -297,6 +297,22 @@ def get_queue_done(self, project):
         return result
 
 
+class ProjectCountsSerializer(ProjectSerializer):
+    class Meta:
+        model = Project
+        fields = [
+            'id',
+            'task_number',
+            'finished_task_number',
+            'total_predictions_number',
+            'total_annotations_number',
+            'num_tasks_with_annotations',
+            'useful_annotation_number',
+            'ground_truth_number',
+            'skipped_annotations_number',
+        ]
+
+
 class ProjectOnboardingSerializer(serializers.ModelSerializer):
     class Meta:
         model = ProjectOnboarding

label_studio/projects/urls.py

@@ -19,6 +19,7 @@
     # CRUD
     path('', api.ProjectListAPI.as_view(), name='project-list'),
     path('<int:pk>/', api.ProjectAPI.as_view(), name='project-detail'),
+    path('counts/', api.ProjectCountsListAPI.as_view(), name='project-counts-list'),
     # Get next task
     path('<int:pk>/next/', api.ProjectNextTaskAPI.as_view(), name='project-next'),
     # Label stream history

label_studio/tests/test_project.py

@@ -2,6 +2,13 @@
 
 import pytest
 from django.db.models.query import QuerySet
+from django.test import TestCase
+from django.urls import reverse
+from django.utils.http import urlencode
+from organizations.models import Organization
+from projects.models import Project
+from rest_framework.test import APIClient
+from tasks.models import Task
 from tests.utils import make_project
 from users.models import User
 
@@ -40,3 +47,45 @@ def test_project_all_members(business_client):
 
     assert isinstance(members, QuerySet)
     assert isinstance(members.first(), User)
+
+
+class TestProjectCountsListAPI(TestCase):
+    @classmethod
+    def setUpTestData(cls):
+        cls.user = User.objects.create_user(username='testuser', email='[email protected]', password='testpassword')
+        cls.organization = Organization.objects.create(title='testorganization')
+        cls.user.active_organization = cls.organization
+        cls.user.save()
+        cls.project_1 = Project.objects.create(title='Project 1', organization=cls.organization)
+        cls.project_2 = Project.objects.create(title='Project 2', organization=cls.organization)
+        Task.objects.create(project=cls.project_1, data={'text': 'Task 1'})
+        Task.objects.create(project=cls.project_1, data={'text': 'Task 2'})
+        Task.objects.create(project=cls.project_2, data={'text': 'Task 3'})
+
+    def get_url(self, **params):
+        return f'{reverse("projects:api:project-counts-list")}?{urlencode(params)}'
+
+    def test_get_counts(self):
+
+        client = APIClient()
+        client.force_authenticate(user=self.user)
+        response = client.get(self.get_url(include='id,task_number,finished_task_number,total_predictions_number'))
+        self.assertEqual(response.status_code, 200)
+        self.assertEqual(response.json()['count'], 2)
+        self.assertEqual(
+            response.json()['results'],
+            [
+                {
+                    'id': self.project_1.id,
+                    'task_number': 2,
+                    'finished_task_number': 0,
+                    'total_predictions_number': 0,
+                },
+                {
+                    'id': self.project_2.id,
+                    'task_number': 1,
+                    'finished_task_number': 0,
+                    'total_predictions_number': 0,
+                },
+            ],
+        )

web/dist/apps/labelstudio/version.json

@@ -1,6 +1,6 @@
 {
-  "message": "chore: OPTIC-1337: Update tooltips (#6737)",
-  "commit": "1747ab0387b57ca5eb91e31288f25e69ff905630",
-  "date": "2024-12-11T13:08:10.000Z",
+  "message": "fix: OPTIC-1418: Improve Organization Membership API usage to reduce latency (#6780)",
+  "commit": "ca1da7a2dc34dfd512d3d1dd71bf722ef4019f66",
+  "date": "2024-12-16T15:03:14.000Z",
   "branch": "develop"
 }

web/dist/libs/datamanager/version.json

@@ -1,6 +1,6 @@
 {
-  "message": "chore: OPTIC-1337: Update tooltips (#6737)",
-  "commit": "1747ab0387b57ca5eb91e31288f25e69ff905630",
-  "date": "2024-12-11T13:08:10.000Z",
+  "message": "fix: OPTIC-1418: Improve Organization Membership API usage to reduce latency (#6780)",
+  "commit": "ca1da7a2dc34dfd512d3d1dd71bf722ef4019f66",
+  "date": "2024-12-16T15:03:14.000Z",
   "branch": "develop"
 }

web/dist/libs/editor/version.json

@@ -1,6 +1,6 @@
 {
-  "message": "chore: OPTIC-1337: Update tooltips (#6737)",
-  "commit": "1747ab0387b57ca5eb91e31288f25e69ff905630",
-  "date": "2024-12-11T13:08:10.000Z",
+  "message": "fix: OPTIC-1418: Improve Organization Membership API usage to reduce latency (#6780)",
+  "commit": "ca1da7a2dc34dfd512d3d1dd71bf722ef4019f66",
+  "date": "2024-12-16T15:03:14.000Z",
   "branch": "develop"
 }

web/libs/datamanager/src/stores/AppStore.js

@@ -479,7 +479,7 @@ export const AppStore = types
     }),
 
     fetchUsers: flow(function* () {
-      const list = yield self.apiCall("users");
+      const list = yield self.apiCall("users", { __useQueryCache: 60 * 1000 });
 
       self.users.push(...list);
     }),

web/libs/datamanager/src/utils/api-proxy/index.js

@@ -155,13 +155,26 @@ export class APIProxy {
       let responseMeta;
       const alwaysExpectJSON = options?.alwaysExpectJSON === undefined ? true : options.alwaysExpectJSON;
 
+      let shouldUseQueryCache = false;
       try {
         const finalParams = {
           ...(methodSettings.params ?? {}),
           ...(urlParams ?? {}),
           ...(this.sharedParams ?? {}),
         };
 
+        if (finalParams.__useQueryCache && methodSettings.queryCache) {
+          shouldUseQueryCache = true;
+
+          const cachedData = methodSettings.queryCache(finalParams);
+
+          if (cachedData) {
+            return cachedData;
+          }
+
+          delete finalParams.__useQueryCache;
+        }
+
         const { method, url: apiCallURL } = this.createUrl(
           methodSettings.path,
           finalParams,
@@ -247,7 +260,13 @@ export class APIProxy {
                 : { ok: true };
 
             if (methodSettings.convert instanceof Function) {
-              return await methodSettings.convert(responseData);
+              const convertedData = await methodSettings.convert(responseData);
+
+              if (shouldUseQueryCache) {
+                methodSettings.queryCache(finalParams, convertedData);
+              }
+
+              return convertedData;
             }
 
             responseResult = responseData;
@@ -268,6 +287,10 @@ export class APIProxy {
         writable: false,
       });
 
+      if (shouldUseQueryCache) {
+        methodSettings.queryCache(finalParams, responseResult);
+      }
+
       return responseResult;
     };
   }