Raise exception when running other than a sync recipe with output STREAMING_ENDPOINT

Author: mhham

dataikuapi/dss/recipe.py

@@ -77,6 +77,7 @@ def run(self, job_type="NON_RECURSIVE_FORCED_BUILD", partitions=None, wait=True,
         :rtype: :class:`dataikuapi.dss.job.DSSJob`
         """
         project = self.client.get_project(self.project_key)
+        settings = self.get_settings()
         outputs = project.get_flow().get_graph().get_successor_computables(self)
 
         if len(outputs) == 0:
@@ -90,11 +91,16 @@ def run(self, job_type="NON_RECURSIVE_FORCED_BUILD", partitions=None, wait=True,
             "COMPUTABLE_SAVED_MODEL": "SAVED_MODEL",
             "COMPUTABLE_STREAMING_ENDPOINT": "STREAMING_ENDPOINT",
         }
+
+        if first_output["type"] == "COMPUTABLE_STREAMING_ENDPOINT" and not isinstance(settings, SyncRecipeSettings):
+            raise Exception(
+                "Cannot run recipe with output type STREAMING_ENDPOINT. Use a dataikuapi.dss.continuousactivity.DSSContinuousActivity instead")
+
         if first_output["type"] in object_type_map:
             jd = project.new_job(job_type)
             jd.with_output(first_output["ref"], object_type=object_type_map[first_output["type"]], partition=partitions)
         else:
-            raise Exception("recipe has unsuported output type {}, can't run it".format(first_output["type"]))
+            raise Exception("Recipe has unsupported output type {}, can't run it".format(first_output["type"]))
 
         if wait:
             return jd.start_and_wait()