async def METHOD_NAME(self, inputs: Dict[str, Any]) -> Dict[str, Any]:
    """
    The default implementation for the dataflow.run operation is the uctx
    mode. This mode is when we map unique strings to a list of inputs to be
    given to the respective string's context.
    """
    inputs_created = {}
    definitions = self.config.dataflow.definitions
    for ctx_str, val_defs in inputs.items():
        inputs_created[ctx_str] = [
            Input(
                value=val_def["value"],
                definition=definitions[val_def["definition"]],
            )
            for val_def in val_defs
        ]
    async with self.subflow(self.config.dataflow) as octx:
        results = [
            {(await ctx.handle()).as_string(): result}
            async for ctx, result in octx.run(inputs_created)
        ]
    return {"results": results}