Function getPyError

plugins/python/redisgears_python.c:5191–5246

}

char* getPyError() {
    if(!PyErr_Occurred()){
        return NULL;
    }
    PyObject *pType, *pValue, *pTraceback;
    PyErr_Fetch(&pType, &pValue, &pTraceback);
    PyErr_NormalizeException(&pType, &pValue, &pTraceback);
    PyObject *pMsg = NULL;
    if (pType == GearsFlatError) {
        // flat error, return the message only!
        pMsg = PyObject_Str(pValue);
    }
    if (!pMsg) {
        PyObject *pModuleName = PyUnicode_FromString("traceback");
        PyObject *pModule = PyImport_Import(pModuleName);
        if(pythonConfig.attemptTraceback && pTraceback != NULL && pModule != NULL){
            PyObject *pFunc = PyObject_GetAttrString(pModule, "format_exception");
            if(pFunc != NULL){
                if(PyCallable_Check(pFunc)){
                    PyObject *pCall = PyObject_CallFunctionObjArgs(pFunc, pType, pValue, pTraceback, NULL);
                    if(pCall){
                        pMsg = PyObject_Str(pCall);
                        GearsPyDecRef(pCall);
                    }
                }
                GearsPyDecRef(pFunc);
            }
            GearsPyDecRef(pModule);
        }
        GearsPyDecRef(pModuleName);
    }
    if(!pMsg){
        PyObject *pStrFormat = PyUnicode_FromString("Error type: %s, Value: %s");
        PyObject* pStrType = PyObject_Str(pType);
        PyObject* pStrValue = PyObject_Str(pValue);
        PyObject *pArgs = PyTuple_New(2);
        PyTuple_SetItem(pArgs, 0, pStrType);
        PyTuple_SetItem(pArgs, 1, pStrValue);
        pMsg = PyUnicode_Format(pStrFormat, pArgs);
        GearsPyDecRef(pArgs);
        GearsPyDecRef(pStrFormat);
    }
    char *msg = (char*)PyUnicode_AsUTF8AndSize(pMsg, NULL);
    char* err =  RG_STRDUP(msg);
    GearsPyDecRef(pMsg);
    if(pType){
        GearsPyDecRef(pType);
    }
    if(pValue){
        GearsPyDecRef(pValue);
    }
    if(pTraceback){
        GearsPyDecRef(pTraceback);
    }
    return err;
}

void fetchPyError(ExecutionCtx* rctx) {