so a user task will continue to request a particular datatype, but that datatype will be provided by

def source_nodes

as in the example above