Skip to content

Commit aa6552e

Browse files
committed
Validate dynamic pipeline source resolving
1 parent eeeff39 commit aa6552e

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/zenml/pipelines/pipeline_definition.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -289,7 +289,12 @@ def resolve(self) -> "Source":
289289
Returns:
290290
The pipeline source.
291291
"""
292-
return source_utils.resolve(self.entrypoint, skip_validation=True)
292+
# We need to validate that the source is loadable for dynamic pipelines,
293+
# as the orchestration environment will need to load the source.
294+
skip_validation = not self.is_dynamic
295+
return source_utils.resolve(
296+
self.entrypoint, skip_validation=skip_validation
297+
)
293298

294299
@property
295300
def source_object(self) -> Any:

0 commit comments

Comments
 (0)