keep it async to match before

voxel51 · Nov 22, 2024 · d621680 · d621680
1 parent 632f140
commit d621680
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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`