    def input(cls, *schema) -> 'Pipeline':
        """
        Start a new pipeline chain.

        Args:
            schema (list): The schema for the values being inputted into the pipeline.

        Returns:
            Pipeline: Pipeline ready to be chained.

        Examples:
            >>> from towhee import pipe
            >>> p = pipe.input('a', 'b', 'c')
        """
        dag_dict = {}
        output_schema = cls._check_schema(schema)
        uid = InputConst.name
        dag_dict[uid] = cls._nop_node_dict(output_schema, output_schema)
        return cls(dag_dict)
Start a new pipeline chain.

Args:
schema (list): The schema for the values being inputted into the pipeline.

Returns:
Pipeline: Pipeline ready to be chained.

Examples:
>>> from towhee import pipe
>>> p = pipe.input('a', 'b', 'c')
towhee/runtime/pipeline.py