Ricky Zhang
01/10/2023, 8:44 PMKalise Richmond
01/10/2023, 9:26 PMAndrew Huang
01/10/2023, 9:33 PMJohn Lewis
01/10/2023, 10:52 PM@flow(task_runner=DaskTaskRunner(address="<http://my-dask-cluster>"))
Kalise Richmond
01/10/2023, 11:12 PMJohn Lewis
01/10/2023, 11:56 PMKalise Richmond
01/11/2023, 12:02 AMJohn Lewis
01/11/2023, 12:10 AMAndrew Huang
01/11/2023, 12:17 AMJohn Lewis
01/11/2023, 12:26 AM@flow(task_runner=DaskTaskRunner(
cluster_class="dask_kubernetes.operator.kubecluster.kubecluster.KubeCluster",
cluster_kwargs={
"image": "my-docker-image-with-dask-and-prefect",
},
adapt_kwargs={"minimum": 1, "maximum": 1},
))
Joseph Desjardins
01/11/2023, 1:14 AM