Skip to content

Commit 3fd0538

Browse files
authored
fix(vdp): fix create pipeline input parameters (#225)
Because - some changes are reverted in previous release This commit - fix create pipeline input parameters
1 parent a91cceb commit 3fd0538

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

instill/clients/pipeline.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,9 +235,17 @@ def list_pipelines(
235235
def create_pipeline(
236236
self,
237237
namespace_id: str,
238-
pipeline: pipeline_interface.Pipeline,
238+
name: str,
239+
description: str,
240+
recipe: dict,
239241
async_enabled: bool = False,
240242
) -> pipeline_interface.CreateNamespacePipelineResponse:
243+
pipeline = pipeline_interface.Pipeline(
244+
id=name,
245+
description=description,
246+
)
247+
pipeline.recipe.update(recipe)
248+
241249
if async_enabled:
242250
return RequestFactory(
243251
method=self.host.async_client.CreateNamespacePipeline,

0 commit comments

Comments
 (0)