Anatoly Myachev
03/23/2022, 8:20 PMDaskTaskRunner
that use dask_cloudprovider.aws.FargateCluster
? There is no logs in Orion UI except 'task-b610b3b0-0' - Crash detected! Execution was interrupted by an unexpected exception.
and RuntimeError: IOLoop is closed
but it's possible to see it in CloudWatch console. It contains the following error: Exception: 'RuntimeError("Cannot orchestrate task run \'9987d480-fad1-433a-9749-077a63fbdc0a\'. Failed to connect to API at <http://orion:4200/api/>.")'
. Note: Orion is deployed on Kubernetes via orion kubernetes-manifest
command.Anna Geller
KubernetesFlowRunner
, then it makes much more sense to use KubeCluster
instead of FargateCluster
? Would you want to give it a try?Anna Geller
Anna Geller
Anatoly Myachev
03/23/2022, 8:33 PMKubeCluster
. However, I am experimenting with a possible case where there are not enough resources in the current Kubernetes cluster and I want to perform part of the load in AWS cluster (EKS/ECS). So in this case, work will occur with two different clusters.
Current K8s cluster is a k3s running on one AWS host.Anna Geller
Anna Geller
KubeCluster
. If you're interested, you can follow the dask-task-runner tag or the kube-cluster tag on Discourse to get notified about any tutorials/content/recipes about it
but of course, if you would want to build and contribute one, that would be super appreciated as well!Anatoly Myachev
03/23/2022, 8:51 PM