'Send the `import_task_created` event for this task. Return a list of
tasks that should continue through the pipeline. By default, this is a
list containing only the task itself, but plugins can replace the task
with new ones.'

def handle_created(self, session):

    tasks = plugins.send('import_task_created', session=session, task=self)
    if (not tasks):
        tasks = [self]
    else:
        tasks = [t for inner in tasks for t in inner]
    return tasks
