python streaming job