(nifi-minifi-cpp) 03/37: Rebase fix

[ad...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

adebreceni pushed a commit to branch minifi-api-reduced
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git

commit 7be07f99032e68468c2916504f12be3a1f7e1751
Author: Adam Debreceni <ad...@apache.org>
AuthorDate: Thu Mar 6 12:22:12 2025 +0100

    Rebase fix
---
 extensions/python/PythonCreator.h | 2 +-
 libminifi/src/Funnel.cpp          | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/extensions/python/PythonCreator.h b/extensions/python/PythonCreator.h
index b326d34dc..647f3255a 100644
--- a/extensions/python/PythonCreator.h
+++ b/extensions/python/PythonCreator.h
@@ -124,7 +124,7 @@ class PythonCreator : public minifi::core::CoreComponentImpl {
         factory = std::make_unique<PythonObjectFactory>(path.string(), script_name.string(),
           PythonProcessorType::MINIFI_TYPE, std::vector<std::filesystem::path>{python_lib_path, std::filesystem::path{pathListings.value()}}, qualified_module_name);
       }
-      if (!registered_classes_.emplace(class_name, factory.get()).second) {
+      if (registered_classes_.emplace(class_name, factory.get()).second) {
         core::getClassLoader().registerClass(class_name, std::move(factory));
       } else {
         logger_->log_warn("Ignoring duplicate python processor at '{}' with class '{}'", path.string(), class_name);
diff --git a/libminifi/src/Funnel.cpp b/libminifi/src/Funnel.cpp
index fee7ccf78..a3ef769f3 100644
--- a/libminifi/src/Funnel.cpp
+++ b/libminifi/src/Funnel.cpp
@@ -16,11 +16,12 @@
  */
 
 #include "Funnel.h"
+#include "minifi-cpp/core/ProcessContext.h"
 
 namespace org::apache::nifi::minifi {
 
-void Funnel::onSchedule(core::ProcessContext&, core::ProcessSessionFactory&) {
-  addAutoTerminatedRelationship(Success);
+void Funnel::onSchedule(core::ProcessContext& context, core::ProcessSessionFactory&) {
+  context.addAutoTerminatedRelationship(Success);
 }
 
 }  // namespace org::apache::nifi::minifi