Skip to content

[flytekit-java] Add typed transform inputs #3260

@andresgomezfrr

Description

@andresgomezfrr

Motivation: Why do you think this is important?

This feature allows the users to know the specific inputs from a task at development time. This is really important when you are working with a remote task that is developed by other users.

Goal: What should the final outcome look like, ideally?

The final goal is to use the input class in the WorkflowBuilder instead of passing the input into the SdkTransform using the withInput(...) method that forces you to know the attribute names of the input class.

Example

previous way

    SdkNode<SumTask.SumOutput> sumNode =
        builder.apply("fib-3", new SumTask().withInput("fib1", fib1).withInput("fib2", fib2));

new way

    SdkNode<SumTask.SumOutput> sumNode =
        builder.apply("fib-3", new SumTask(), SumTask.SumInput.create(fib1, fib2));

Describe alternatives you've considered

None

Propose: Link/Inline OR Additional context

flyteorg/flytekit-java#175

Are you sure this issue hasn't been raised already?

  • Yes

Have you read the Code of Conduct?

  • Yes

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or requestflytekit-javaFlytekit Java related issue

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions