database-stream-processor
database-stream-processor copied to clipboard
Force pipeline termination from pipeline manager
The runner handles the /shutdown
command by first calling controller.stop()
and then sending a termination message to the actix dispatch loop. Both operations can be slow or even get stuck in some cases. We will need a way to enforce eventual termination from the pipeline manager by killing the process/pod after a timeout.
@lalithsuresh