@pipeline.stage
def log_files(session, task):
 if isinstance(task, SingletonImportTask):
  log.info(u'Singleton: {0}', displayable_path(task.item['path']))
 elif task.items:
  log.info(u'Album: {0}', displayable_path(task.paths[0]))
  for item in task.items:
   log.info(u'  {0}', displayable_path(item['path']))

@ pipeline . stage def log_files ( session , task ) : if isinstance ( task , SingletonImportTask ) : log . info ( u'Singleton: {0}' , displayable_path ( task . item [ 'path' ] ) ) elif task . items : log . info ( u'Album: {0}' , displayable_path ( task . paths [ 0 ] ) ) for item in task . items : log . info ( u'  {0}' , displayable_path ( item [ 'path' ] ) )
a coroutine to log each file to be imported .