The ingestion job needs a signal in order to know it should stop ingesting the stream and revert back to a consistent. In the prototype implementation, this was done OnFailOrCancel. However, we should provide a first-class way to conclude an ingestion job.