ai-yunying/douyin/flow/deployment.py

import sys
sys.path.append(r'.')
import time
from prefect.deployments import run_deployment
from prefect import flow, serve
from douyin.flow import check_page,conversation,unread_msg

def main():
    check_page_deploy = check_page.check_page_ok_flow.to_deployment('ai-yunying')
    reply_to_user_deploy = conversation.reply_to_user_flow.to_deployment('ai-yunying')
    unread_msg_depoly = unread_msg.unread_msg_flow.to_deployment('ai-yunying')
    stranger_msg_depoly = unread_msg.stranger_msg_flow.to_deployment('ai-yunying')
    serve(check_page_deploy,reply_to_user_deploy, unread_msg_depoly, stranger_msg_depoly)

if __name__ == "__main__":
    main()