@pipeline.mutator_stage
def plugin_stage(session, func, task):
 if task.skip:
  return
 func(session, task)
 task.reload()

@ pipeline . mutator_stage def plugin_stage ( session , func , task ) : if task . skip : return func ( session , task ) task . reload ( )
a coroutine that calls the given function with each non-skipped import task .