在celery中，有没有一种简单的方法来创建一个或多个任务，以便我可以使用它们自动重新启动工作进程？目标是每次从github获取新源代码时，我的部署都会自动重新启动所有子celery工作进程。因此，我可以向该机器上的管理celery实例发送一个restartWorkers()任务，该任务将停止该机器上的所有celery工作进程（实际上是stopwait），并使用新模块重新启动它们。
计划是每台机器都有：
- 管理节点[队列：管理，特定于机器] - 负责管理机器上的其余工作进程，根据需要启动新节点并杀死旧节点 - 工作节点[队列：git修订特定，工作进程特定，特定于机器] - 实际负责执行工作
看起来我需要的代码在dist_packages/celery/bin/celeryd_multi.py的某个地方，但是启动工作进程的源代码相当不透明，我无法确定它应该如何工作或在哪里启动节点。（看起来shutdown_nodes是正确的代码来调用杀死进程，我正在缓慢地通过它来调试以弄清楚我的参数应该是什么）
是否存在重启节点(self, nodes)函数/函数，我可以调用它，还是我将从python内部运行shell脚本？
此外，是否有一种比杀死和重新启动进程更简单的方法来重新加载Python中的源代码？如果我知道重新加载模块实际上是有效的（实验表明它不是。对函数的更改不会传播，直到我重新启动进程），我将只是这样做而不是使用管理节点的间接方式。
编辑：我现在可以关机，感谢broadcast（谢谢mihael。如果我的声望更高，我会点赞）。有没有广播重启的方法？有pool_restart，但它不会杀死节点，这意味着它不会更新源代码。
我一直在研究celery.bin.celeryd:WorkerCommand().run()中的一些幕后源代码，但是在调用之前和之后都发生了一些奇怪的事情，因此我不能仅调用该函数并完成它，因为它会崩溃。从python脚本调用shell命令来运行另一个python脚本毫无意义，我无法相信我是第一个想要这样做的人。
计划是每台机器都有：
- 管理节点[队列：管理，特定于机器] - 负责管理机器上的其余工作进程，根据需要启动新节点并杀死旧节点 - 工作节点[队列：git修订特定，工作进程特定，特定于机器] - 实际负责执行工作
看起来我需要的代码在dist_packages/celery/bin/celeryd_multi.py的某个地方，但是启动工作进程的源代码相当不透明，我无法确定它应该如何工作或在哪里启动节点。（看起来shutdown_nodes是正确的代码来调用杀死进程，我正在缓慢地通过它来调试以弄清楚我的参数应该是什么）
是否存在重启节点(self, nodes)函数/函数，我可以调用它，还是我将从python内部运行shell脚本？
此外，是否有一种比杀死和重新启动进程更简单的方法来重新加载Python中的源代码？如果我知道重新加载模块实际上是有效的（实验表明它不是。对函数的更改不会传播，直到我重新启动进程），我将只是这样做而不是使用管理节点的间接方式。
编辑：我现在可以关机，感谢broadcast（谢谢mihael。如果我的声望更高，我会点赞）。有没有广播重启的方法？有pool_restart，但它不会杀死节点，这意味着它不会更新源代码。
我一直在研究celery.bin.celeryd:WorkerCommand().run()中的一些幕后源代码，但是在调用之前和之后都发生了一些奇怪的事情，因此我不能仅调用该函数并完成它，因为它会崩溃。从python脚本调用shell命令来运行另一个python脚本毫无意义，我无法相信我是第一个想要这样做的人。