From 862d8cf5f84a5b4e3cb8815818362f615029b513 Mon Sep 17 00:00:00 2001 From: Snowykami Date: Thu, 17 Apr 2025 22:26:52 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=8D=A2=E4=B8=BA=E7=BE=A4=E6=99=96?= =?UTF-8?q?=E9=A9=B1=E5=8A=A8=E5=99=A8=E5=96=9C=E6=AC=A2=E7=9A=84partial?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sync.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sync.py b/sync.py index 23b03e6..ddda414 100644 --- a/sync.py +++ b/sync.py @@ -1,5 +1,6 @@ import asyncio from typing import Any, Callable, Coroutine +from functools import partial import aiofiles import yaml from pydantic import BaseModel @@ -73,9 +74,9 @@ async def main(): for image in config.images: if len(image.tags) > 0: 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: - 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) failed_tasks = sum(1 for result in results if result is not None and result != 0)