From d621680028cb5f083dbc9729251d5612277219fd Mon Sep 17 00:00:00 2001 From: Stuart Wheaton Date: Fri, 22 Nov 2024 15:30:38 -0500 Subject: [PATCH] keep it async to match before --- fiftyone/operators/delegated.py | 2 +- fiftyone/operators/executor.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/fiftyone/operators/delegated.py b/fiftyone/operators/delegated.py index 314059f3689..b27056c3772 100644 --- a/fiftyone/operators/delegated.py +++ b/fiftyone/operators/delegated.py @@ -519,7 +519,7 @@ async def _execute_operator(self, doc): ctx.request_params["target"] = "outputs" ctx.request_params["results"] = result - outputs = resolve_type_with_context(operator, ctx) + outputs = await resolve_type_with_context(operator, ctx) if outputs is not None: outputs_schema = outputs.to_json() except (AttributeError, Exception): diff --git a/fiftyone/operators/executor.py b/fiftyone/operators/executor.py index 57846363f5e..a797cf0ebdf 100644 --- a/fiftyone/operators/executor.py +++ b/fiftyone/operators/executor.py @@ -379,10 +379,10 @@ async def resolve_type(registry, operator_uri, request_params): ) await ctx.resolve_secret_values(operator._plugin_secrets) - return resolve_type_with_context(operator, ctx) + return await resolve_type_with_context(operator, ctx) -def resolve_type_with_context(operator, context): +async def resolve_type_with_context(operator, context): """Resolves the "inputs" or "outputs" schema of an operator with the given context. Args: operator: the :class:`fiftyone.operators.Operator`