diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessFlowManager.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessFlowManager.java
index 565857006c81..641b8db99407 100644
--- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessFlowManager.java
+++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessFlowManager.java
@@ -76,7 +76,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.net.ssl.SSLContext;
 import java.net.URL;
 import java.util.ArrayList;
 import java.util.Collection;
@@ -86,6 +85,7 @@
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.function.BooleanSupplier;
+import javax.net.ssl.SSLContext;
 
 import static java.util.Objects.requireNonNull;
 
@@ -221,7 +221,7 @@ public Port createLocalOutputPort(final String id, final String name) {
 
     @Override
     public ProcessGroup createProcessGroup(final String id) {
-        return new StandardProcessGroup(id, statelessEngine.getControllerServiceProvider(),
+        final ProcessGroup created = new StandardProcessGroup(id, statelessEngine.getControllerServiceProvider(),
             statelessEngine.getProcessScheduler(),
             statelessEngine.getPropertyEncryptor(),
             statelessEngine.getExtensionManager(),
@@ -232,6 +232,9 @@ public ProcessGroup createProcessGroup(final String id) {
             null,
             group -> null,
             statelessEngine.getAssetManager());
+
+        onProcessGroupAdded(created);
+        return created;
     }
 
     @Override