5

我正在尝试使用 Django 将 python 脚本作为芹菜任务运行。我遇到的问题是，一旦脚本开始运行，任务就认为它已经完成。我最初在 tasks.py 文件中使用 subprocess.popen()，但意识到这意味着一旦发出 popen() 命令，任务就会完成。我修改了我的 tasks.py 代码以调用我的 python 脚本中的一个函数，该函数运行该脚本；但是，这仍然会像任务立即完成一样执行。我很困惑，因为在花中它说任务已完成，但在芹菜日志中它正在输出我正在运行的脚本中定义的日志数据。我找到了以下相关帖子。我相信我正在遵循它的建议，从 tasks.py 执行 python 函数。

任务.py：

def exe(workDir, cancelRun):
    sys.path.append(workDir)
    import run

    if cancelRun=='True':
        task_id=exe.request.id
        revoke(task_id,terminate=True)
    else:
        run.runModel(workDir)
        task_id=exe.request.id
        return task_id

运行模型功能代码：

def runModel(scendir):
    fullpath=scendir+'/run.py'
    os.chdir(scendir)
    p=Process(target=myMain,args=(scendir,))
    p.start()
    p.join()
4

1 回答 1

1

如果您在终端上运行命令（由您的任务执行的命令）会发生什么？如果它立即返回，则可能是它自己守护进程，比如说 via fork()。

另一种测试原因的方法是使用 Django shell: python manage.py shell，然后执行必要的导入以手动调用您的函数。

于 2014-07-11T00:43:13.920 回答