Function registerCreateArgs

plugins/python/redisgears_python.c:1915–1940

}

static void* registerCreateArgs(FlatExecutionPlan* fep, PyObject *kargs, ExecutionMode mode){
    const char* reader = RedisGears_GetReader(fep);
    if (strcmp(reader, "CommandReader") == 0){
        return registerCreateCommandArgs(kargs);
    }

    char* defaultPrefixStr = "*";
    const char* prefixStr = defaultPrefixStr;
    PyObject* prefix = GearsPyDict_GetItemString(kargs, "prefix");
    if(prefix){
        if(PyUnicode_Check(prefix)){
            prefixStr = PyUnicode_AsUTF8AndSize(prefix, NULL);
        }else{
            PyErr_SetString(GearsError, "regex argument must be a string");
            return NULL;
        }
    }

    if (strcmp(reader, "KeysReader") == 0){
        return registerCreateKeysArgs(kargs, prefixStr, mode);
    }else if (strcmp(reader, "StreamReader") == 0){
        return registerCreateStreamArgs(kargs, prefixStr, mode);
    }
    PyErr_SetString(GearsError, "given reader does not exists or does not support register");
    return NULL;
}

static PyObject* registerExecution(PyObject *self, PyObject *args, PyObject *kargs){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();