Resolve UserWarning Log

integrations/gitlab/gitlab_integration/core/async_fetcher.py

@@ -15,6 +15,7 @@
     User,
     GroupMember,
     ProjectFile,
+    ProjectLabel,
 )
 from loguru import logger
 
@@ -44,14 +45,14 @@ async def fetch_single(
         ],
         *args,
     ) -> Union[
-        RESTObject,
         RESTObject,
         ProjectPipelineJob,
         ProjectPipeline,
         Issue,
         Project,
         Group,
         ProjectFile,
+        ProjectLabel,
     ]:
         with ThreadPoolExecutor() as executor:
             return await get_event_loop().run_in_executor(executor, fetch_func, *args)
@@ -92,6 +93,7 @@ async def fetch_batch(
             List[RESTObject],
             List[Dict[str, Any]],
             GitlabList,
+            List[ProjectLabel],
         ]
     ]:
         def fetch_page(

integrations/gitlab/gitlab_integration/gitlab_service.py

@@ -20,6 +20,7 @@
     ProjectFile,
     ProjectPipeline,
     ProjectPipelineJob,
+    ProjectLabel,
     Hook,
 )
 from gitlab_integration.core.async_fetcher import AsyncFetcher
@@ -550,9 +551,15 @@ async def get_all_projects(self) -> typing.AsyncIterator[List[Project]]:
     @classmethod
     async def async_project_labels_wrapper(cls, project: Project) -> dict[str, Any]:
         try:
-            labels = await anyio.to_thread.run_sync(project.labels.list)
-            serialized_labels = [label.attributes for label in labels]
-            return {"__labels": serialized_labels}
+            all_labels = [
+                label.attributes
+                async for labels_batch in AsyncFetcher.fetch_batch(
+                    fetch_func=project.labels.list
+                )
+                for label in typing.cast(List[ProjectLabel], labels_batch)
+            ]
+
+            return {"__labels": all_labels}
         except Exception as e:
             logger.warning(
                 f"Failed to get labels for project={project.path_with_namespace}. error={e}"