This check, and the one below verifies that self.state, which at this point is always equal to SHUTDOWN, regardless of the actual state of the pipeline:
|
if self.state != PipelineState.SHUTDOWN: |
A minimal fix would be to retrieve the pipeline state before this check. But I actually think that we shouldn't try to track pipeline state in a local variable and should just always request it from the pipeline.
This check, and the one below verifies that
self.state, which at this point is always equal to SHUTDOWN, regardless of the actual state of the pipeline:feldera/python/feldera/sql_context.py
Line 324 in 089a9fd
A minimal fix would be to retrieve the pipeline state before this check. But I actually think that we shouldn't try to track pipeline state in a local variable and should just always request it from the pipeline.