diff --git a/src/Manager.cpp b/src/Manager.cpp index 11d11a26d..1db452d5b 100755 --- a/src/Manager.cpp +++ b/src/Manager.cpp @@ -143,8 +143,7 @@ Manager::createManagedSequence(std::string sequenceName, uint32_t queueIndex) if (sequenceName.empty()) { this->mCurrentSequenceIndex++; this->mManagedSequences.insert( - { KP_DEFAULT_SESSION + std::to_string(this->mCurrentSequenceIndex), - sq }); + { KP_DEFAULT_SESSION, sq }); } else { // TODO: Check if sequence doesn't already exist this->mManagedSequences.insert({ sequenceName, sq }); diff --git a/src/include/kompute/Manager.hpp b/src/include/kompute/Manager.hpp index 973a00397..d7a08c49c 100644 --- a/src/include/kompute/Manager.hpp +++ b/src/include/kompute/Manager.hpp @@ -126,8 +126,7 @@ class Manager SPDLOG_DEBUG("Kompute Manager evalOp Default triggered"); this->mCurrentSequenceIndex++; this->evalOp(tensors, - KP_DEFAULT_SESSION + - std::to_string(this->mCurrentSequenceIndex), + KP_DEFAULT_SESSION, std::forward(params)...); } @@ -179,8 +178,7 @@ class Manager SPDLOG_DEBUG("Kompute Manager evalOpAsyncDefault triggered"); this->mCurrentSequenceIndex++; this->evalOpAsync(tensors, - KP_DEFAULT_SESSION + - std::to_string(this->mCurrentSequenceIndex), + KP_DEFAULT_SESSION, std::forward(params)...); } @@ -222,8 +220,7 @@ class Manager void evalOpAwaitDefault(uint64_t waitFor = UINT64_MAX) { SPDLOG_DEBUG("Kompute Manager evalOpAwaitDefault triggered"); - this->evalOpAwait(KP_DEFAULT_SESSION + - std::to_string(this->mCurrentSequenceIndex), + this->evalOpAwait(KP_DEFAULT_SESSION, waitFor); }