Function PythonSessionCtx_CreateWithId

plugins/python/redisgears_python.c:813–873

}

static PythonSessionCtx* PythonSessionCtx_CreateWithId(const char* id, const char* desc, const char** requirementsList, size_t requirementsListLen, bool forceReqReinstallation){
    // creating a new global dict for this session
    RedisGearsPy_LOCK

    PyObject* globalDict = PyDict_Copy(pyGlobals);

    PythonSessionCtx* session = RG_ALLOC(sizeof(*session));
    *session = (PythonSessionCtx){
            .sessionId = RG_STRDUP(id),
            .sessionDesc = desc? RG_STRDUP(desc) : NULL,
            .refCount = 1,
            .globalsDict = globalDict,
            .isInstallationNeeded = false,
            .profiler = PyObject_CallFunction(profileCreateFunction, NULL),
            .registrations = array_new(char*, 10),
            .srctx = NULL,
            .linkedTo = LinkedTo_None,
            .deadNode = NULL,
            .fullSerialization = false,

    };
    pthread_mutex_init(&session->registrationsLock, NULL);

    session->requirements = array_new(PythonRequirementCtx*, 10);

    if (!forceReqReinstallation) {
        // lets see if we already have the requirements installed
        for(size_t i = 0 ; i < requirementsListLen ; ++i){
            PythonRequirementCtx *req = PythonRequirementCtx_Get(requirementsList[i]);
            if (!req) {
                session->isInstallationNeeded = true;
                break;
            } else {
                session->requirements = array_append(session->requirements , req);
            }
        }
    } else {
        session->isInstallationNeeded = true;
    }

    if (session->isInstallationNeeded) {
        while(array_len(session->requirements) > 0) {
            PythonRequirementCtx *req = array_pop(session->requirements);
            PythonRequirementCtx_Free(req);
        }
        for(size_t i = 0 ; i < requirementsListLen ; ++i){
            PythonRequirementCtx* req = PythonRequirementCtx_Create(requirementsList[i]);

            if(!req){
                PythonSessionCtx_Free(session);
                session = NULL;
                break;
            }
            session->requirements = array_append(session->requirements , req);
        }
    }

    RedisGearsPy_UNLOCK