1
0
Fork 0

restore single output in chain pipeline stages

This commit is contained in:
Sean Sube 2023-02-21 08:14:04 -06:00
parent 061718b477
commit 82016a163a
Signed by: ssube
GPG Key ID: 3EED7B957D362AF1
3 changed files with 5 additions and 5 deletions

View File

@ -17,12 +17,12 @@ def persist_disk(
_params: ImageParams, _params: ImageParams,
source: Image.Image, source: Image.Image,
*, *,
output: List[str], output: str,
stage_source: Image.Image, stage_source: Image.Image,
**kwargs, **kwargs,
) -> Image.Image: ) -> Image.Image:
source = stage_source or source source = stage_source or source
dest = save_image(server, output[0], source) dest = save_image(server, output, source)
logger.info("saved image to %s", dest) logger.info("saved image to %s", dest)
return source return source

View File

@ -30,14 +30,14 @@ def hash_value(sha, param: Param):
def json_params( def json_params(
output: List[str], outputs: List[str],
params: ImageParams, params: ImageParams,
size: Size, size: Size,
upscale: Optional[UpscaleParams] = None, upscale: Optional[UpscaleParams] = None,
border: Optional[Border] = None, border: Optional[Border] = None,
) -> Any: ) -> Any:
json = { json = {
"output": output, "outputs": outputs,
"params": params.tojson(), "params": params.tojson(),
} }

View File

@ -760,7 +760,7 @@ def chain():
context, context,
params, params,
empty_source, empty_source,
output=output, output=output[0],
size=size, size=size,
needs_device=device, needs_device=device,
) )