feat: Support multiple projects

src/ai/backend/manager/container_registry/gitlab.py

@@ -21,33 +21,36 @@ async def fetch_repositories(self, sess: aiohttp.ClientSession) -> AsyncIterator
             self.registry_info["gitlab_project"],
         )
 
-        encoded_project_id = urllib.parse.quote(f"{name}/{gitlab_project}", safe="")
-        repo_list_url = (
-            f"https://gitlab.com/api/v4/projects/{encoded_project_id}/registry/repositories"
-        )
-
-        headers = {
-            "Accept": "application/json",
-            "PRIVATE-TOKEN": access_token,
-        }
-        page = 1
-
-        while True:
-            async with sess.get(
-                repo_list_url,
-                headers=headers,
-                params={"per_page": 30, "page": page},
-            ) as response:
-                if response.status == 200:
-                    data = await response.json()
-
-                    for repo in data:
-                        yield repo["path"]
-                    if "next" in response.headers.get("Link", ""):
-                        page += 1
+        projects = gitlab_project.split(",")
+
+        for project in projects:
+            encoded_project_id = urllib.parse.quote(f"{name}/{project}", safe="")
+            repo_list_url = (
+                f"https://gitlab.com/api/v4/projects/{encoded_project_id}/registry/repositories"
+            )
+
+            headers = {
+                "Accept": "application/json",
+                "PRIVATE-TOKEN": access_token,
+            }
+            page = 1
+
+            while True:
+                async with sess.get(
+                    repo_list_url,
+                    headers=headers,
+                    params={"per_page": 30, "page": page},
+                ) as response:
+                    if response.status == 200:
+                        data = await response.json()
+
+                        for repo in data:
+                            yield repo["path"]
+                        if "next" in response.headers.get("Link", ""):
+                            page += 1
+                        else:
+                            break
                     else:
-                        break
-                else:
-                    raise RuntimeError(
-                        f"Failed to fetch repositories! {response.status} error occurred."
-                    )
+                        raise RuntimeError(
+                            f"Failed to fetch repositories for project {project}! {response.status} error occurred."
+                        )