Skip to content

Commit e00029d

Browse files
authored
py: do not pause before shutting down the pipeline (feldera#1788)
Signed-off-by: Abhinav Gyawali <22275402+abhizer@users.noreply.github.com>
1 parent 2ffd757 commit e00029d

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

python/feldera/sql_context.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -394,14 +394,12 @@ def pause(self):
394394

395395
def shutdown(self):
396396
"""
397-
Pauses and shuts down the pipeline.
397+
Shuts down the pipeline.
398398
"""
399399

400400
if self.state == PipelineState.SHUTDOWN:
401401
return
402402

403-
self.pause()
404-
405403
self.client.shutdown_pipeline(self.pipeline_name)
406404
self.state = PipelineState.SHUTDOWN
407405

0 commit comments

Comments
 (0)