InputTask

A Task whose input the SDK resolves from the @task.stub TaskFlow call site in the Python Dag file and injects.

The type argument is the TaskInput the task expects, and it is the only place that declaration lives. Each of its public fields binds by name, ignoring case and underscores, so the stub's snake_case arguments reach camelCase Java fields with nothing declared.

public class Summarize implements InputTask<SummarizeInput> {
  @Override
  public void execute(Context context, Client client, SummarizeInput input) {
    // input.region, input.transformed
  }
}

Plain Task stays the right choice for a task the Dag file calls with no arguments.

Type Parameters

See also