def from_session_dict(self, session_data, *args, **kwargs):
        """Takes session saved data to continue pipeline and merges with any
        new extra argument needed. Returns tuple with next pipeline index
        entry, arguments and keyword arguments to continue the process."""
        args = args[:] + tuple(map(ctype_to_model, session_data["args"]))

        kwargs = kwargs.copy()
        kwargs.update((key, ctype_to_model(val)) for key, val in session_data["kwargs"].iteritems())
        return (session_data["next"], args, kwargs)

    def from_session_dict(self, session_data, *args, **kwargs):
        """Takes session saved data to continue pipeline and merges with any
        new extra argument needed. Returns tuple with next pipeline index
        entry, arguments and keyword arguments to continue the process."""
        import pickle
        session_data = pickle.loads(session_data['social_data'])
        args = args[:] + tuple(map(ctype_to_model, session_data['args']))

        kwargs = kwargs.copy()
        saved_kwargs = dict((key, ctype_to_model(val))
                            for key, val in session_data['kwargs'].iteritems())
        saved_kwargs.update((key, val)
                            for key, val in kwargs.iteritems())
        return (session_data['next'], args, saved_kwargs)