Skip to content
This repository was archived by the owner on Aug 25, 2024. It is now read-only.
This repository was archived by the owner on Aug 25, 2024. It is now read-only.

df: base: op: Support single output without auto-defined I/O #1350

@johnandersen777

Description

@johnandersen777
 478                     if auto_def_outputs and len(self.parent.op.outputs) == 1:
 479                         if inspect.isasyncgen(result):
 480
 481                             async def convert_asyncgen(outputs):
 482                                 async for yielded_output in outputs:
 483                                     yield {
 484                                         list(self.parent.op.outputs.keys())[
 485                                             0
 486                                         ]: yielded_output
 487                                     }
 488
 489                             result = convert_asyncgen(result)
 490                         elif result is not None and valid_return_none:
 491                             result = {
 492                                 list(self.parent.op.outputs.keys())[0]: result
 493                             }

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions