我正在使用Celery3.1.16代理(运行RabbitMQ)和多个Celeryworker，celeryd通过主管守护。问题在于任务更新。当我更新我的tasks.py文件时，celeryworker运行旧代码。Celery启动命令:/home/my_project/bin/celery-B--autoreload--app=my_app.celery:appworker--loglevel=INFO我在djangosettings.py中包含任务文件:CELERY_IMPORTS=['my_app.tasks']pyinotify已安装并工作(我猜是这样)，celery日志的一部分:

我正在使用pyinotify来监视文件夹以了解何时在其中创建文件。当创建某些文件时，我想移动它们。问题是文件一创建(很明显)，我的程序就会尝试移动它，甚至在它完全写入磁盘之前。有没有办法让pyinotify等到文件完全写入磁盘后才通知我文件已创建？或者有什么简单的方法可以在我收到通知后让python等待移动它直到它完成写入？ 最佳答案 让pyinotify对IN_CLOSE_WRITE使用react事件:wm.add_watch(watched_dir,pyinotify.IN_CLOSE_WRITE,proc_fun=MyProc