internal.PipelineSourceFunction - Node documentation