zhang_crawl_bio/ui/backend/tests/mytests/celery_worker_t.py

import asyncio
import json
from pathlib import Path
import sys
import sys
# 为了避免耦合，微服务，可能确实要将上级的上级目录作为一个单独的进程来处理，此目录作为一个单独的UI项目
sys.path.append(str(Path(r'G:\code\upwork\zhang_crawl_bio\ui\backend')))
from src.services.celery_worker import CeleryWorker
from utils.logu import get_logger
logger = get_logger('mytests', file=True)

async def main():
    worker = CeleryWorker()
    status = await worker.check_worker_status()
    json_dump = json.dumps(status, indent=4)
    logger.info(json_dump)

if __name__ == "__main__":
    asyncio.run(main())