@gen.engine
def GetRegistry(logs_store, path, callback):
 contents = ''
 contents = (yield gen.Task(logs_store.Get, path, must_exist=False))
 if (contents is None):
  callback(None)
  return
 buf = cStringIO.StringIO(contents)
 buf.seek(0)
 files = []
 entries = buf.readlines()
 for f in entries:
  if f:
   files.append(f.strip())
 buf.close()
 callback(files)

@ gen . engine def GetRegistry ( logs_store , path , callback ) : contents = '' contents = ( yield gen . Task ( logs_store . Get , path , must_exist = False ) ) if ( contents is None ) : callback ( None ) return buf = cStringIO . StringIO ( contents ) buf . seek ( 0 ) files = [ ] entries = buf . readlines ( ) for f in entries : if f : files . append ( f . strip ( ) ) buf . close ( ) callback ( files )
open the registry at path in s3 .