Rebase

Author: atobiszei

src/mediapipe_internal/mediapipegraphdefinition.cpp

@@ -263,7 +263,7 @@ Status MediapipeGraphDefinition::create(std::shared_ptr<MediapipeGraphExecutor>&
     GraphIdGuard graphIdGuard(*(this->queue)); // TODO timeout?
     pipeline = std::make_shared<MediapipeGraphExecutor>(getName(), std::to_string(getVersion()),
         this->config, this->inputTypes, this->outputTypes, this->inputNames, this->outputNames,
-        this->pythonNodeResourcesMap, this->llmNodeResourcesMap, this->pythonBackend, this->reporter.get(), std::move(graphIdGuard));
+        this->pythonNodeResourcesMap, this->genAiServableMap, this->pythonBackend, this->reporter.get(), std::move(graphIdGuard));
     return status;
 }
 

src/mediapipe_internal/mediapipegraphexecutor.hpp

@@ -211,10 +211,10 @@ class MediapipeGraphExecutor {
             SPDLOG_DEBUG("Mediapipe failed to execute. Failed to receive all output packets");
             return Status(StatusCode::MEDIAPIPE_EXECUTION_ERROR, "Unknown error during mediapipe execution");
         }
-        timer.stop(PROCESS);
+        /*timer.stop(PROCESS);
         double processTime = timer.template elapsed<std::chrono::microseconds>(PROCESS);
         OBSERVE_IF_ENABLED(this->mediapipeServableMetricReporter->getProcessingTimeMetric(executionContext), processTime);
-        INCREMENT_IF_ENABLED(this->mediapipeServableMetricReporter->getResponsesMetric(executionContext));
+        INCREMENT_IF_ENABLED(this->mediapipeServableMetricReporter->getResponsesMetric(executionContext));*/
         SPDLOG_DEBUG("Received all output stream packets for graph: {}", this->name);
         return StatusCode::OK;
     }