[pipelines] Pull out trigger for source pipelines as its own type

A separate trigger is produced for each source, and each trigger must be fired. Instead, the app should create one trigger and pass it to each source.