add/skip types to match what PublicAPIFlowController.java sends

Author: FChataigner

dataikuapi/dss/flow.py

@@ -515,8 +515,9 @@ def get_successor_computables(self, node, as_type="dict"):
         return self._convert_nodes_list(computables, as_type)
 
     def _convert_nodes_list(self, nodes, as_type):
+        actual_nodes = [node for node in nodes if node['type'] != 'RUNNABLE_IMPLICIT_RECIPE']
         if as_type == "object" or as_type == "objects":
-            return [self._get_object_from_graph_node(node) for node in nodes]
+            return [self._get_object_from_graph_node(node) for node in actual_nodes]
         else:
             return nodes
 
@@ -529,6 +530,8 @@ def _get_object_from_graph_node(self, node):
             return DSSManagedFolder(self.flow.client, self.flow.project.project_key, node["ref"])
         elif node["type"] == "COMPUTABLE_SAVED_MODEL":
             return DSSSavedModel(self.flow.client, self.flow.project.project_key, node["ref"])
+        elif node["type"] == "COMPUTABLE_STREAMING_ENDPOINT":
+            return DSSStreamingEndpoint(self.flow.client, self.flow.project.project_key, node["ref"])
         else:
             # TODO add streaming elements
             raise Exception("unsupported node type: %s" % node["type"])