tlpipe.timestream.timestream_task.TimestreamTask.cast_input

TimestreamTask.cast_input(input)[source]

Override to support accepting pipeline inputs of various types.