Subversion Repositories SmartDukaan

Rev

Rev 12279 | Rev 12283 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 12279 Rev 12281
Line 34... Line 34...
34 
    try:
 34 
    try:
35 
        while True:
 35 
        while True:
36 
            requests = session.query(CompetitorPricingRequest).filter(or_(CompetitorPricingRequest.isProcessed==False,CompetitorPricingRequest.isProcessed==None)).order_by(asc(CompetitorPricingRequest.requestId)).all()
 36 
            requests = session.query(CompetitorPricingRequest).filter(or_(CompetitorPricingRequest.isProcessed==False,CompetitorPricingRequest.isProcessed==None)).order_by(asc(CompetitorPricingRequest.requestId)).all()
37 
            if requests ==[] or requests is None:
 37 
            if requests ==[] or requests is None:
38 
                print "No new request to process, sleeeeeeping....."
 38 
                print "No new request to process, sleeeeeeping....."
- 
 
 39 
                close_session()
- 
 
 40 
                collected = gc.collect()
- 
 
 41 
                print "Garbage collector: collected %d objects." % (collected)
39 
                time.sleep(600)
 42 
                time.sleep(600)
40 
            for request in requests:
 43 
            for request in requests:
41 
                fetchDetails(request)
 44 
                fetchDetails(request)
42 
                request.isProcessed = True
 45 
                request.isProcessed = True
43 
                session.commit()
 46 
                session.commit()