On-demand execution of pipelines triggered by input

[yamalight]

Currently pipeline should be running to handle input.
Investigate whether it's possible to spin up workers on input and shut them down after processing is done. (keep source running?)