harbor-admin/image-manager
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更换为群晖驱动器喜欢的partial
All checks were successful
Sync Container Images / sync-images (push) Successful in 1m0s
Details

Browse Source
This commit is contained in:
远野千束 2025-04-17 22:26:52 +08:00
parent 104a6822bc
commit 862d8cf5f8
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sync.py
View File

@ -1,5 +1,6 @@
import asyncio import asyncio
from typing import Any, Callable, Coroutine from typing import Any, Callable, Coroutine
from functools import partial
import aiofiles import aiofiles
import yaml import yaml
from pydantic import BaseModel from pydantic import BaseModel
@ -73,9 +74,9 @@ async def main():
for image in config.images: for image in config.images:
if len(image.tags) > 0: if len(image.tags) > 0:
for tag in image.tags: for tag in image.tags:
tasks.append(limited_task(semaphore, lambda s=f"{image.source}:{tag}", t=f"{image.target}:{tag}": docker_task(s, t))) tasks.append(limited_task(semaphore, partial(docker_task, image.source, f"{image.target}:{tag}")))
else: else:
tasks.append(limited_task(semaphore, lambda s=image.source, t=image.target: docker_task(s, t))) tasks.append(limited_task(semaphore, partial(docker_task, image.source, image.target)))
results = await asyncio.gather(*tasks) results = await asyncio.gather(*tasks)
failed_tasks = sum(1 for result in results if result is not None and result != 0) failed_tasks = sum(1 for result in results if result is not None and result != 0)