def _init_task(self, class_path, options, task_config):
    task_class = import_global(class_path)
    task_config = self._parse_task_options(options, task_class, task_config)
    return (task_class, task_config)
def _init_task(self, class_path, options, task_config):
    task_class = import_global(class_path)
    task_config = self._parse_task_options(options, task_class, task_config)
    return (task_class, task_config)