@pipeline.stage
def manipulate_files(session, task):
 if (not task.skip):
  if task.should_remove_duplicates:
   task.remove_duplicates(session.lib)
  task.manipulate_files(move=session.config['move'], copy=session.config['copy'], write=session.config['write'], link=session.config['link'], session=session)
 task.finalize(session)

@ pipeline . stage def manipulate_files ( session , task ) : if ( not task . skip ) : if task . should_remove_duplicates : task . remove_duplicates ( session . lib ) task . manipulate_files ( move = session . config [ 'move' ] , copy = session . config [ 'copy' ] , write = session . config [ 'write' ] , link = session . config [ 'link' ] , session = session ) task . finalize ( session )
a coroutine that performs necessary file manipulations *after* items have been added to the library and finalizes each task .