accept_batches.py

gistfile1.py

from cts.inventory import BagList, Bag


def accepted_on(bag):
    accepted_on = None
    for event in bag.events:
        if event.type in ("BagAcceptedEvent",): #, "ReconEvent"):
            accepted_on = event.end
        if event.type=="BagRejectedEvent" or event.type=="BagCancelledEvent": 
            accepted_on = None  # clear accepted_on if it's been later
                                # rejected or cancelled
    return accepted_on
        

def accepted_bags():
    for bag in BagList.find_bags(projectId="ndnp"):
        try:
            bag = Bag.find_bag("ndnp", bag.id)  # get full form of bag so
            # that it has field like
            # currentBagVersion
            # populated
        except Exception, e:
            print e
            continue
        timestamp = accepted_on(bag)
        if timestamp:
            yield timestamp, bag

for date, bag in sorted(accepted_bags()):
    try:
        if not bag.isTest:
            print "%s_ver%.02d" % (bag.id, bag.currentBagVersion)
    except Exception, e:
        print e