Skip to content

Commit a797c42

Browse files
committed
python: add silent bootstrap feature
Signed-off-by: Gerd Zellweger <mail@gerdzellweger.com>
1 parent 1414c0f commit a797c42

2 files changed

Lines changed: 17 additions & 0 deletions

File tree

python/feldera/pipeline.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -672,6 +672,10 @@ def approve(self, silent_bootstrap: bool = False):
672672
`bootstrap_policy=BootstrapPolicy.AWAIT_APPROVAL` and is currently in the
673673
AWAITINGAPPROVAL state. The pipeline will wait for explicit user approval
674674
before proceeding with the bootstrapping process.
675+
676+
:param silent_bootstrap: Set True to bootstrap with output connectors
677+
disabled, so no records are emitted during the bootstrap phase.
678+
False by default.
675679
"""
676680

677681
self.client.approve_pipeline(self.name, silent_bootstrap=silent_bootstrap)

python/feldera/rest/feldera_client.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -672,9 +672,22 @@ def pause_pipeline(
672672
def approve_pipeline(
673673
self,
674674
pipeline_name: str,
675+
silent_bootstrap: bool = False,
675676
):
677+
"""
678+
Approve a pipeline awaiting approval to proceed with bootstrapping.
679+
680+
:param pipeline_name: The name of the pipeline to approve.
681+
:param silent_bootstrap: Set True to bootstrap with output connectors
682+
disabled, so no records are emitted during the bootstrap phase.
683+
False by default.
684+
"""
685+
686+
params = {"silent_bootstrap": "true"} if silent_bootstrap else {}
687+
676688
self.http.post(
677689
path=f"/pipelines/{pipeline_name}/approve",
690+
params=params,
678691
)
679692

680693
def stop_pipeline(

0 commit comments

Comments
 (0)