flask_init.py 文件源码

def task_prerun_handler(task_id = None, args = None, **kwargs):
    mongoengine.connect(**celery_config.mongoengine_SETTINGS)
    #information about task are located in headers for task messages
    # using the task protocol version 2.
    print("task_prerun_handler:" + str(task_id))
    task_monitor_ob = task_monitor.objects(task_id= task_id).first()
    task_monitor_ob.task_prerun_args = args
    task_monitor_ob.celery_stask_status = 1
    task_monitor_ob.update_time = datetime.now(tz = pytz.timezone('Asia/Shanghai'))
    task_monitor_ob.save()