[GitHub] [nifi-minifi-cpp] adamdebreceni commented on a diff in pull request #1363: Add support and tests for advanced MQTT features

[GitBox <gi...@apache.org>]

adamdebreceni commented on code in PR #1363:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1363#discussion_r919960389


##########
docker/test/integration/minifi/core/SingleNodeDockerCluster.py:
##########
@@ -142,6 +142,30 @@ def deploy(self, name):
 
         self.containers[name].deploy()
 
-    def deploy_flow(self):
+    def deploy_flow(self, container_name=None):
+        if container_name is not None:
+            if container_name not in self.containers:
+                logging.error('Could not start container because it is not found: \'%s\'', container_name)
+                return
+            self.containers[container_name].deploy()
+            return
         for container in self.containers.values():
             container.deploy()
+
+    def stop_flow(self, container_name):
+        if container_name not in self.containers:
+            logging.error('Could not stop container because it is not found: \'%s\'', container_name)
+            return
+        self.containers[container_name].stop()
+
+    def kill_flow(self, container_name):
+        if container_name not in self.containers:
+            logging.error('Could not kill container because it is not found: \'%s\'', container_name)
+            return
+        self.containers[container_name].kill()
+
+    def restart_flow(self, container_name):
+        if container_name not in self.containers:
+            logging.error('Could not stop restart because it is not found: \'%s\'', container_name)

Review Comment:
   possible typo? `Could not ~stop~ restart ...`



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@nifi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org