Function getGearsSession

plugins/python/redisgears_python.c:2937–2960

}

static PyObject* getGearsSession(PyObject *cls, PyObject *args){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();
    PyObject* res;
    if(!ptctx->currSession){
        Py_INCREF(Py_None);
        res = Py_None;
    }else{
        PyExecutionSession* pyExSes = PyObject_New(PyExecutionSession, &PyExecutionSessionType);
        pyExSes->s = PythonSessionCtx_ShallowCopy(ptctx->currSession);
        pyExSes->crtCtx = getCommandReaderTriggerCtx(ptctx);
        pyExSes->cmdCtx = getCommandCtx(ptctx);

        if(pyExSes->crtCtx){
            pyExSes->crtCtx = RedisGears_CommandReaderTriggerCtxGetShallowCopy(pyExSes->crtCtx);
        }

        if(pyExSes->cmdCtx){
           pyExSes->cmdCtx = RedisGears_CommandCtxGetShallowCopy(pyExSes->cmdCtx);
       }

        res = (PyObject*)pyExSes;
    }
    return res;
}

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