To enable compile time type checking changed the pipiline sync to return a tuple and used implicit conversions on a pipeline wrapper to convert to the correct scala types