diff --git a/swh/loader/tar/loader.py b/swh/loader/tar/loader.py
index fb205e8..d173d3c 100644
--- a/swh/loader/tar/loader.py
+++ b/swh/loader/tar/loader.py
@@ -1,107 +1,107 @@
-# Copyright (C) 2015-2017  The Software Heritage developers
+# Copyright (C) 2015-2018  The Software Heritage developers
 # See the AUTHORS file at the top-level directory of this distribution
 # License: GNU General Public License version 3, or any later version
 # See top-level LICENSE file for more information
 
 
 import os
 import tempfile
 import shutil
 
 from swh.core import tarball
 from swh.loader.core.loader import SWHLoader
 from swh.loader.dir import loader
 from swh.loader.tar import utils
 from swh.model import hashutil
 
 
 class TarLoader(loader.DirLoader):
     """Tarball loader implementation.
 
     This is a subclass of the :class:DirLoader as the main goal of
     this class is to first uncompress a tarball, then provide the
     uncompressed directory/tree to be loaded by the DirLoader.
 
     This will:
 
     - creates an origin (if it does not exist)
     - creates a fetch_history entry
     - creates an origin_visit
     - uncompress locally the tarball in a temporary location
     - process the content of the tarballs to persist on swh storage
     - clean up the temporary location
     - write an entry in fetch_history to mark the loading tarball end (success
       or failure)
     """
     CONFIG_BASE_FILENAME = 'loader/tar'
 
     ADDITIONAL_CONFIG = {
         'extraction_dir': ('string', '/tmp')
     }
 
     def __init__(self, logging_class='swh.loader.tar.TarLoader', config=None):
         super().__init__(logging_class=logging_class, config=config)
 
     def load(self, *, tar_path, origin, visit_date, revision, occurrences):
         """Load a tarball in `tarpath` in the Software Heritage Archive.
 
         Args:
             tar_path: tarball to import
             origin (dict): an origin dictionary as returned by
               :func:`swh.storage.storage.Storage.origin_get_one`
             visit_date (str): the date the origin was visited (as an
               isoformatted string)
             revision (dict): a revision as passed to
               :func:`swh.storage.storage.Storage.revision_add`, excluding the
               `id` and `directory` keys (computed from the directory)
             occurrences (list of dicts): the occurrences to create in the
               generated origin visit. Each dict contains a 'branch' key with
               the branch name as value.
         """
         # Shortcut super() as we use different arguments than the DirLoader.
-        SWHLoader.load(self, tar_path=tar_path, origin=origin,
-                       visit_date=visit_date, revision=revision,
-                       occurrences=occurrences)
+        return SWHLoader.load(self, tar_path=tar_path, origin=origin,
+                              visit_date=visit_date, revision=revision,
+                              occurrences=occurrences)
 
     def prepare(self, *, tar_path, origin, visit_date, revision, occurrences):
         """1. Uncompress the tarball in a temporary directory.
            2. Compute some metadata to update the revision.
 
         """
         if 'type' not in origin:  # let the type flow if present
             origin['type'] = 'tar'
 
         # Prepare the extraction path
         extraction_dir = self.config['extraction_dir']
         os.makedirs(extraction_dir, 0o755, exist_ok=True)
         dir_path = tempfile.mkdtemp(prefix='swh.loader.tar-',
                                     dir=extraction_dir)
 
         # add checksums in revision
 
         self.log.info('Uncompress %s to %s' % (tar_path, dir_path))
         nature = tarball.uncompress(tar_path, dir_path)
 
         if 'metadata' not in revision:
             artifact = utils.convert_to_hex(hashutil.hash_path(tar_path))
             artifact['name'] = os.path.basename(tar_path)
             artifact['archive_type'] = nature
             artifact['length'] = os.path.getsize(tar_path)
             revision['metadata'] = {
                 'original_artifact': [artifact],
             }
 
         super().prepare(dir_path=dir_path,
                         origin=origin,
                         visit_date=visit_date,
                         revision=revision,
                         release=None,
                         occurrences=occurrences)
 
     def cleanup(self):
         """Clean up temporary directory where we uncompress the tarball.
 
         """
         dir_path = self.dir_path
         if dir_path and os.path.exists(dir_path):
             shutil.rmtree(dir_path)
diff --git a/swh/loader/tar/tasks.py b/swh/loader/tar/tasks.py
index eb45604..5429fcb 100644
--- a/swh/loader/tar/tasks.py
+++ b/swh/loader/tar/tasks.py
@@ -1,25 +1,26 @@
-# Copyright (C) 2015-2017  The Software Heritage developers
+# Copyright (C) 2015-2018  The Software Heritage developers
 # See the AUTHORS file at the top-level directory of this distribution
 # License: GNU General Public License version 3, or any later version
 # See top-level LICENSE file for more information
 
 from swh.scheduler.task import Task
 
 from swh.loader.tar.loader import TarLoader
 
 
 class LoadTarRepository(Task):
     """Import a directory to Software Heritage
 
     """
     task_queue = 'swh_loader_tar'
 
     def run_task(self, *, tar_path, origin, visit_date, revision, occurrences):
         """Import a tarball into swh.
 
         Args: see :func:`TarLoader.load`.
         """
         loader = TarLoader()
         loader.log = self.log
-        loader.load(tar_path=tar_path, origin=origin, visit_date=visit_date,
-                    revision=revision, occurrences=occurrences)
+        return loader.load(tar_path=tar_path, origin=origin,
+                           visit_date=visit_date, revision=revision,
+                           occurrences=occurrences)