'Handle a new task to be emitted by the factory.
Emit the `import_task_created` event and increment the
`imported` count if the task is not skipped. Return the same
task. If `task` is None, do nothing.'

def _create(self, task):

    if task:
        tasks = task.handle_created(self.session)
        self.imported += len(tasks)
        return tasks
    return []
