python - 在代码更改时自动重新加载 Dask 工作器容器

Question

我有下面的 Dask 代码，它提交 N 个 worker ，其中每个 worker 都在 Docker 容器中实现:

default_sums = client.map(process_asset_defaults, build_worker_args(req, numWorkers))
future_total_sum = client.submit(sum, default_sums)
total_defaults_sum = future_total_sum.result()

哪里 process_asset_defaults是一个 worker 的方法。
问题是在开发环境中，当我更改工作人员的代码时，我需要手动重新启动所有容器以使更改生效。
有没有办法在不重新启动工作人员的情况下使用新代码重新加载工作人员？
注意:代码驻留在 Docker 卷中，我使用 Visual Studio Code 直接在卷中更改它。

Answer 1

您可以使用文件的当前内容创建一个变量，然后创建一个循环来检查文件内容是否与之前的内容不相等，如果不是，您可以做一些事情

before = open("/code/app/worker.py").read()

while True:
   current = open("/code/app/worker.py").read()
   if current != before:
       dostuff()
       before = current