Function setGearsSession

plugins/python/redisgears_python.c:2969–2994

}

static PyObject* setGearsSession(PyObject *cls, PyObject *args){
    if(PyTuple_Size(args) != 1){
        PyErr_SetString(GearsError, "Wrong number of args given to setGearsSession");
        return NULL;
    }

    PythonThreadCtx* ptctx = GetPythonThreadCtx();

    PyObject* s = PyTuple_GetItem(args, 0);
    if(s == Py_None){
        ptctx->currSession = NULL;
    }else{
        if(!PyObject_IsInstance((PyObject*)s, (PyObject*)&PyExecutionSessionType)){
            PyErr_SetString(GearsError, "Given object is not of type GearsSession");
            return NULL;
        }

        PyExecutionSession* pyExSes = (PyExecutionSession*)s;
        ptctx->currSession = pyExSes->s;
        ptctx->crtCtx = pyExSes->crtCtx;
        ptctx->commandCtx = pyExSes->cmdCtx;
    }

    Py_INCREF(Py_None);
    return Py_None;
}

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