Skip to content

Commit 32fb02b

Browse files
committed
Revert "Raise exception when running other than a sync recipe with output STREAMING_ENDPOINT"
This reverts commit 4e0ed83.
1 parent 0fd6967 commit 32fb02b

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

dataikuapi/dss/recipe.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,6 @@ 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-
settings = self.get_settings()
8180
outputs = project.get_flow().get_graph().get_successor_computables(self)
8281

8382
if len(outputs) == 0:
@@ -91,16 +90,11 @@ def run(self, job_type="NON_RECURSIVE_FORCED_BUILD", partitions=None, wait=True,
9190
"COMPUTABLE_SAVED_MODEL": "SAVED_MODEL",
9291
"COMPUTABLE_STREAMING_ENDPOINT": "STREAMING_ENDPOINT",
9392
}
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-
9993
if first_output["type"] in object_type_map:
10094
jd = project.new_job(job_type)
10195
jd.with_output(first_output["ref"], object_type=object_type_map[first_output["type"]], partition=partitions)
10296
else:
103-
raise Exception("Recipe has unsupported output type {}, can't run it".format(first_output["type"]))
97+
raise Exception("recipe has unsuported output type {}, can't run it".format(first_output["type"]))
10498

10599
if wait:
106100
return jd.start_and_wait()

0 commit comments

Comments
 (0)