Subversion Repositories SmartDukaan

            print "Error: unable to send email."

            print "Error: unable to send email."

def populateScrapingResults(val):

def populateScrapingResults(val):

    try:

    try:

        flipkartDetails = fetchDetails(val.fkSerialNumber,scraper)

        flipkartDetails = fetchDetails(val.fkSerialNumber,scraper)

        val.flipkartDetails = flipkartDetails 

        val.flipkartDetails = flipkartDetails 

    except Exception as e:

    except Exception as e:

        print "Unable to fetch details of",val.fkSerialNumber

        print "Unable to fetch details of",val.fkSerialNumber

        print e

        print e

        val.flipkartDetails = None

        val.flipkartDetails = None

        while(count<5 and endOffset<len(itemInfo)):

        while(count<5 and endOffset<len(itemInfo)):

            endOffset = startOffset + 20

            endOffset = startOffset + 20

            if (endOffset >= len(itemInfo)):

            if (endOffset >= len(itemInfo)):

                endOffset = len(itemInfo)

                endOffset = len(itemInfo)

            print "pool offset start end count"+str(startOffset)+" "+str(endOffset)+" "+str(count)

            print "pool offset start end count"+str(startOffset)+" "+str(endOffset)+" "+str(count)

            pool.map(populateScrapingResults,itemInfo[startOffset:endOffset])

            pool.map(populateScrapingResults,itemInfo[startOffset:endOffset])

            #t = Process(target=decideCategory,args=(itemInfo[startOffset:endOffset], scraper))

            #t = Process(target=decideCategory,args=(itemInfo[startOffset:endOffset], scraper))

            #t = threading.Thread(target=partial(decideCategory, itemInfo[startOffset:endOffset], scraper))

            #t = threading.Thread(target=partial(decideCategory, itemInfo[startOffset:endOffset], scraper))

            #t = threading.Thread(target=partial(test, startOffset, endOffset))

            #t = threading.Thread(target=partial(test, startOffset, endOffset))

            #threads.append(t)

            #threads.append(t)

        #threads = []

        #threads = []

        print "terminating while"

        print "terminating while"

        pool.close()

        pool.close()

        pool.join()

        pool.join()

        print "joining threads"

        print "joining threads"

        print "returning offset******"

        print "returning offset******"

        return endOffset

        return endOffset

def sendAutoPricingMail(successfulAutoDecrease,successfulAutoIncrease):

def sendAutoPricingMail(successfulAutoDecrease,successfulAutoIncrease):

    if len(successfulAutoDecrease)==0 and len(successfulAutoIncrease)==0 :

    if len(successfulAutoDecrease)==0 and len(successfulAutoIncrease)==0 :

        return

        return