python - 一起使用 Snakemake 和 Dask 有意义吗?
问题描述
我有一个 Snakemake 工作流程,我一直在使用它来训练 DL TensorFlow 模型。在高层次上,有一些运行时间较长的作业(模型训练)可以并行运行。我想在云上运行这些,这dask-cloudprovider
似乎是一个很有前途的选择,因为我可以在 ECS 上轻松利用 GPU。但是,要做到这一点,我是否必须使用 Dask 函数(也许dask delayed
)重写我的工作流程?或者有什么方法可以让 Snakemake 使用 Dask?
解决方案
如果你在网络上搜索“dask snakemake”,你会发现一个 2017 年的 Github 问题,你可能想通读一遍。这当然是可能的,但需要有人编写集成。
您可能还想尝试 Dask 与 Airflow 的集成,或者更现代一点的 Prefect 库。
推荐阅读
- python - React / Apollo:显示 GraphQL 突变的错误(useMutation 挂钩)
- reactjs - 如何使用 SetInterval 对进度条做出反应
- terraform - Terraform 未部署正确的资源
- group-by - Tableau count 列重复值的次数,按另外两列分组
- android - 保存文件(zip)以在 Android 10 中指定文件夹
- c - 使用大小为 8 的未初始化值导致无效的读取大小?
- flutter - Flutter:如何在构造函数中传递值,以便我可以重用我的小部件?
- javascript - ChartJS 如何将颜色设置为一个栏
- c++ - 如何将新创建的对象添加到数组中
- python - Python中范围内的求和函数