scheduled.py 文件源码

def task_sche_run():
    try:
        print "starting scheduler task"
        task = Task.objects.filter(status='appointed').filter(sche_time__lte=datetime.datetime.now())
        if len(task)>0:
            for mytask in task:
                print "mytask_id"
                print mytask.id
                hosttag = mytask.dbtag
                status = 'running'
                sql = mytask.sqltext
                mycreatetime = mytask.create_time
                mytask.status = status
                mytask.update_time = datetime.datetime.now()
                mytask.save()
                log_incep_op(sql, hosttag, mycreatetime)
                process_runtask.delay(hosttag, sql, mytask)
                #Process(target=process_runtask, args=).start()
    except Exception,e:
        print e