Skip to content

Commit 0fd6967

Browse files
committed
Revert "Check if recipe is a continuous activity"
This reverts commit c6e8a8f.
1 parent c6e8a8f commit 0fd6967

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

dataikuapi/dss/recipe.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -77,13 +77,9 @@ def run(self, job_type="NON_RECURSIVE_FORCED_BUILD", partitions=None, wait=True,
7777
:rtype: :class:`dataikuapi.dss.job.DSSJob`
7878
"""
7979
project = self.client.get_project(self.project_key)
80-
81-
continuous_recipes_names = set(activity.recipe_id for activity in project.list_continuous_activities())
82-
if self.name in continuous_recipes_names:
83-
raise Exception(
84-
"Cannot run continuous recipe. Use a dataikuapi.dss.continuousactivity.DSSContinuousActivity instead")
85-
80+
settings = self.get_settings()
8681
outputs = project.get_flow().get_graph().get_successor_computables(self)
82+
8783
if len(outputs) == 0:
8884
raise Exception("recipe has no outputs, can't run it")
8985

@@ -95,6 +91,11 @@ def run(self, job_type="NON_RECURSIVE_FORCED_BUILD", partitions=None, wait=True,
9591
"COMPUTABLE_SAVED_MODEL": "SAVED_MODEL",
9692
"COMPUTABLE_STREAMING_ENDPOINT": "STREAMING_ENDPOINT",
9793
}
94+
95+
if first_output["type"] == "COMPUTABLE_STREAMING_ENDPOINT" and not isinstance(settings, SyncRecipeSettings):
96+
raise Exception(
97+
"Cannot run recipe with output type STREAMING_ENDPOINT. Use a dataikuapi.dss.continuousactivity.DSSContinuousActivity instead")
98+
9899
if first_output["type"] in object_type_map:
99100
jd = project.new_job(job_type)
100101
jd.with_output(first_output["ref"], object_type=object_type_map[first_output["type"]], partition=partitions)

0 commit comments

Comments
 (0)