Disconnect Client#
Shows how to disconnect a client session, clear client resources, and optionally stop the cluster.
"""Basic client clear/disconnect example with a local cluster."""
from scaler import Client
from scaler.cluster.combo import SchedulerClusterCombo
def main():
cluster = SchedulerClusterCombo(n_workers=10)
client = Client(address=cluster.get_address())
client.clear()
client.disconnect()
cluster.shutdown()
if __name__ == "__main__":
main()
What the example does:
Starts a local cluster and creates a client.
Calls
clear()to cancel unfinished tasks and clear client-owned resources.Calls
disconnect()to close only this client session.
Use disconnect when you want to close one client without stopping the scheduler.
Shutdown behavior#
By default, the scheduler runs in protected mode. See protected for details.
If protected mode is disabled, clients can stop the cluster by calling shutdown().