Function gearsFutureCtx

plugins/python/redisgears_python.c:2868–2902

}

static PyObject* gearsFutureCtx(PyObject *cls, PyObject *args){
    if(PyTuple_Size(args) != 0){
        PyErr_SetString(GearsError, "Future gets no arguments");
        return NULL;
    }

    PythonThreadCtx* ptctx = GetPythonThreadCtx();
    if(!ptctx->currEctx){
        PyErr_SetString(GearsError, "Future object can only be created inside certain execution steps");
        return NULL;
    }

    if(ptctx->pyfutureCreated){
        PyErr_SetString(GearsError, "Can not create async record twice on the same step");
        return NULL;
    }

    char* err = NULL;
    Record *async = RedisGears_AsyncRecordCreate(ptctx->currEctx, &err);
    if(!async){
        if(!err){
            err = RG_STRDUP("Failed creating async record");
        }
        PyErr_SetString(GearsError, err);
        RG_FREE(err);
        return NULL;
    }

    PyFuture* pyfuture = PyObject_New(PyFuture, &PyFutureType);
    pyfuture->asyncRecord = async;
    pyfuture->continueType = 0;
    ptctx->pyfutureCreated = (PyObject*)pyfuture;
    Py_INCREF(ptctx->pyfutureCreated);
    return (PyObject*)pyfuture;
}

static PyObject* registerGearsThread(PyObject *cls, PyObject *args){
    RedisGears_LockHanlderRegister();