Function overrideReply

plugins/python/redisgears_python.c:4590–4623

}

static PyObject* overrideReply(PyObject *cls, PyObject *args){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();

    CommandCtx* commandCtx = getCommandCtx(ptctx);
    if(!commandCtx){
        PyErr_SetString(GearsError, "Can not get command ctx");
        return NULL;
    }

    if(PyTuple_Size(args) != 1){
        PyErr_SetString(GearsError, "Override reply must get a single argument");
        return NULL;
    }

    PyObject* reply = PyTuple_GetItem(args, 0);

    PythonRecord* record = (PythonRecord*)PyObjRecordCreate();
    record->obj = reply;

    Py_INCREF(record->obj);

    char* err = NULL;

    if(RedisGears_CommandCtxOverrideReply(commandCtx, &record->base, &err) != REDISMODULE_OK){
        PyErr_SetString(GearsError, err);
        RG_FREE(err);
        RedisGears_FreeRecord(&record->base);
        return NULL;
    }

    Py_INCREF(Py_None);

    return Py_None;
}

static PyObject* getCommand(PyObject *cls, PyObject *args){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();