ntabris · January 31, 2025 23:56
diff --git a/dask_local_tcp.py b/dask_local_tcp.py
 from dask.distributed import Client

 client = Client("tcp://127.0.0.1:8786")

 print(client)

 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)
	from dask.distributed import Client

	client = Client("tcp://127.0.0.1:8786")

	print(client)

	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)