Function RedisGearsPy_ImportRequirement

plugins/python/redisgears_python.c:6529–6578

}

static int RedisGearsPy_ImportRequirement(RedisModuleCtx *ctx, RedisModuleString **argv, int argc){
    VERIFY_CLUSTER_INITIALIZE(ctx);

    Gears_Buffer* buff = Gears_BufferCreate();

    for(size_t i = 1 ; i < argc ; i++){
        size_t len;
        const char* d = RedisModule_StringPtrLen(argv[i], &len);
        Gears_BufferAdd(buff, d, len);
    }

    Gears_BufferReader br;
    Gears_BufferReaderInit(&br, buff);

    char* err = NULL;
    PythonRequirementCtx* req = PythonRequirement_Deserialize(&br, &err);
    if(!req){
        if(!err){
            err = RG_STRDUP("Failed deserialize requirement");
        }
        RedisModule_ReplyWithError(ctx, err);
        RG_FREE(err);
        Gears_BufferFree(buff);
        return REDISMODULE_OK;
    }

    Gears_BufferFree(buff);

    RedisModuleBlockedClient *bc = RedisModule_BlockClient(ctx, NULL, NULL, NULL, 0);
    PythonRequirementCtx** reqs = array_new(PythonRequirementCtx*, 1);
    reqs = array_append(reqs, req);
    ExecutionPlan* ep = RedisGearsPy_DistributeRequirements(reqs, RedisGearsPy_DoneImportRequirement, bc, &err);
    if(!ep){
        // error here leave us in a state where we have the requirement but others
        // do not, user will see the error and will have to retry.
        if(!err){
            err = RG_STRDUP("Failed create distribute requirements execution on rg.importreq");
        }
        RedisModule_AbortBlock(bc);
        RedisModule_ReplyWithError(ctx, err);
        RG_FREE(err);
    }

    // We are holding a shared ref to the requirement, we need to free it.
    // Notice that this will not cause the requirement to be freed.
    PythonRequirementCtx_Free(req);
    array_free(reqs);

    return REDISMODULE_OK;
}

static int RedisGearsPy_ExportRequirement(RedisModuleCtx *ctx, RedisModuleString **argv, int argc){
    if(argc != 2){