import os
import uuid

from celery.result import AsyncResult
import django

from approve.tasks import add_approve

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'jiuyun.settings')
django.setup()

tasks = []
for i in range(10):
    tasks.append(add_approve.delay(appr_id=uuid.uuid4().hex).id)

print('所有的任务', tasks)
i = 0
while tasks:
    if i >= len(tasks):  i = 0
    task_id = tasks[i]
    try:
        ret = AsyncResult(id=task_id).get(timeout=0.1) # 同步的方法,阻塞
    except:
        continue
    finally:
        i += 1

    print(task_id, ret)
    if ret == 'Ok':
        tasks.remove(task_id) # tasks.pop(-1)
    else:
        print(task_id, '处理失败')