Function PythonRequirementCtx_Create

plugins/python/redisgears_python.c:467–497

}

static PythonRequirementCtx* PythonRequirementCtx_Create(const char* requirement){
#define RAND_SIZE 10
    char rand[RAND_SIZE + 1];
    RedisModule_GetRandomHexChars(rand, RAND_SIZE);
    rand[RAND_SIZE] = '\0';

    // first lets create basePath
    int exitCode = RedisGears_ExecuteCommand(NULL, "notice", "mkdir -p '%s/%s_%s'", venvDir, requirement, rand);
    if(exitCode != 0){
        return NULL;
    }

    PythonRequirementCtx* ret = RG_ALLOC(sizeof(*ret));
    ret->installName = RG_STRDUP(requirement);
    RedisGears_ASprintf(&ret->basePath, "%s/%s_%s", venvDir, ret->installName, rand);
    ret->wheels = array_new(char*, 10);
    // refCount is starting from 2, one hold by RequirementsDict and once by the caller.
    // currently we basically never delete requirements so we will know not to reinstall them
    // to save time
    ret->refCount = 1;
    pthread_mutex_init(&ret->installationLock, NULL);

    ret->isInRequirementsDict = false;

    PythonRequirementCtx_VerifyBasePath(ret);

    ret->isInstalled = false;
    ret->isDownloaded = false;

    return ret;
}

typedef struct{
    const char* fileName;