coiled_cluster_from_node.py

coiled_cluster_from_node.py

### GET CLUSTER AND CLIENT OBJECTS ###

import coiled
cluster = coiled.get_cluster_from_node()
cluster.adapt()
client = cluster.get_client()
print("dask client:", client)

### USER CODE FOLLOWS ###

import dask

# generate random timeseries of data
df = dask.datasets.timeseries(
    "1980", "2005", partition_freq="2w"
).persist()

# perform a groupby with an aggregation
result = df.groupby("name").aggregate({"x": "sum", "y": "max"}).compute()

print(result)