Ignore:
Timestamp:
29/07/09 15:49:51 (10 years ago)
Author:
sdonegan
Message:

Updated to allow inclusion of end date ordering

File:
1 edited

Legend:

Unmodified
Added
Removed
  • TI01-discovery/branches/ingestAutomation-upgrade/OAIBatch/abstractdocumentingester.py

    r5524 r5537  
    417417                        for fileArr in filePresentListArr: 
    418418                                filesPresentList.append(fileArr[0]) 
     419                                 
     420                                #TODO - is above relevant - duplicating functionlaity? 
    419421         
    420422                #create list to to hold files ingest failed on. 
     
    422424                self.deletedFailList = [] 
    423425                 
     426                 
    424427                for filename in filenames: 
    425428                        fullPath = self.discovery_dir + filename 
     
    430433                                #remove this filename from the list of files for this DC already in list (whats left over is to be deleted)  
    431434                                if (thisIngestedID != "") and (len(filesPresentList) != 0): 
    432                                         if thisIngestedID in filesPresentList:                                           
    433                                                 filesPresentList.remove(thisIngestedID)                                  
     435                                        if thisIngestedID in filesPresentList:   
     436                                                filesPresentList.remove(thisIngestedID)                  
    434437                                                 
    435438                #test loop through remaining items in filePresentList - in order to synchronise with ingest directory - these 
    436439                #will need to be removed. 
    437                 for item in filesPresentList: 
    438                         logging.info("NEED to DELETE : " + item + " IN ORDER TO SYNCHRONISE INGEST DIRECTORY WITH DATABASE CONTENTS") 
    439                         DeleteRecord(item) 
    440                         self.deletedFailList.append(item) 
    441                         self._no_files_deleted += 1 
     440                 
     441                #only do this if not in single file mode (or else wverything else gets deleted!) 
     442                if self.indFileToIngest == "": 
     443                        for item in filesPresentList: 
     444                                logging.info("NEED to DELETE : " + item + " IN ORDER TO SYNCHRONISE INGEST DIRECTORY WITH DATABASE CONTENTS")                    
     445                                DeleteRecord(item) 
     446                                self.deletedFailList.append(item) 
     447                                self._no_files_deleted += 1 
    442448                         
    443449                         
Note: See TracChangeset for help on using the changeset viewer.