Function DAGAddOpsFromString

plugins/python/redisgears_python.c:2578–2608

}

static PyObject* DAGAddOpsFromString(PyObject *self, PyObject *args) {
    verifyRedisAILoaded();
    PyDAGRunner *pyDag = (PyDAGRunner *)self;
    if(!_IsDagAPISupported(RedisAI_DAGAddOpsFromString) || !_IsValidDag(pyDag)) {
        return NULL;
    }

    if(PyTuple_Size(args) != 1){
        PyErr_SetString(GearsError, "Wrong number of args");
        return NULL;
    }
    PyObject* ops = PyTuple_GetItem(args, 0);
    if(!PyUnicode_Check(ops)){
        PyErr_SetString(GearsError, "ops argument must be a string");
        return NULL;
    }
    const char* opsStr = PyUnicode_AsUTF8AndSize(ops, NULL);
    RAI_Error *err;
    RedisAI_InitError(&err);
    RedisGears_LockHanlderAcquire(staticCtx);
    if (RedisAI_DAGAddOpsFromString(pyDag->dag, opsStr, err) != REDISMODULE_OK) {
        PyErr_SetString(GearsError, RedisAI_GetError(err));
        RedisAI_FreeError(err);
        RedisGears_LockHanlderRelease(staticCtx);
        return NULL;
    }
    RedisAI_FreeError(err);
    RedisGears_LockHanlderRelease(staticCtx);
    Py_INCREF(self);
    return self;
}

static void FinishAsyncDAGRun(RAI_OnFinishCtx *onFinishCtx, void *private_data) {