shutdown_cluster: [INTERNAL] Shutdown cluster and remove corresponding connections
Description
[INTERNAL] Run this if the pipeline fails during parallel
computation to clean the state. If a cluster is registered, this functions
stops it and removes corresponding connections. Ignores errors. Has no effect
if no cluster is registered.
Usage
shutdown_cluster()
Arguments
Value
No return value, called internally to shutdown cluster