WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

The WorkerSourceTask cancel() method closes the Producer, releasing it's resources. The WorkerSInkTask does not do the same for the Consumer, as it does not override the cancel() method.

WorkerSinkTask should close the consumer if the task is cancelled, as progress for a cancelled task will be discarded anyway.