abstract coordinator system producer creation into a factory
cleanup source in job runne
refactoring to add coordinator stream system consumer