Function runCreateStreamReaderArgs

plugins/python/redisgears_python.c:1485–1497

}

static void* runCreateStreamReaderArgs(const char* pattern, PyObject *kargs){
    const char* defaultFromIdStr = "0-0";
    const char* fromIdStr = defaultFromIdStr;
    PyObject* pyFromId = GearsPyDict_GetItemString(kargs, "fromId");
    if(pyFromId){
        if(!PyUnicode_Check(pyFromId)){
            PyErr_SetString(GearsError, "fromId argument must be a string");
            return NULL;
        }
        fromIdStr = PyUnicode_AsUTF8AndSize(pyFromId, NULL);
    }
    return RedisGears_StreamReaderCtxCreate(pattern, fromIdStr);
}

static void* runCreateKeysReaderArgs(const char* pattern, PyObject *kargs){
    bool noScan = false;