use fireOnOneErrback and consumeErrors in execute_pipeline