'Create an `DagInput` with the given type.
Args:
type_: The Python class which inputs to `DAGPipeline` should be
instances of. `DAGPipeline.input_type` will be this type.'

def __init__(self, type_):

    self.output_type = type_
