Differential D5078 Diff 18198 swh/loader/mercurial/tasks_from_disk.py

Changeset View

Standalone View

swh/loader/mercurial/tasks_from_disk.py

	# Copyright (C) 2020 The Software Heritage developers			# Copyright (C) 2020-2021 The Software Heritage developers
	# See the AUTHORS file at the top-level directory of this distribution			# See the AUTHORS file at the top-level directory of this distribution
	# License: GNU General Public License version 3, or any later version			# License: GNU General Public License version 3, or any later version
	# See top-level LICENSE file for more information			# See top-level LICENSE file for more information

				from typing import Optional

	from celery import shared_task			from celery import shared_task

				from swh.loader.mercurial.utils import parse_visit_date

	from .from_disk import HgArchiveLoaderFromDisk, HgLoaderFromDisk			from .from_disk import HgArchiveLoaderFromDisk, HgLoaderFromDisk


	@shared_task(name=__name__ + ".LoadMercurialFromDisk")			@shared_task(name=__name__ + ".LoadMercurialFromDisk")
	def load_hg(*, url, directory=None, visit_date=None):			def load_hg(
				*, url: str, directory: Optional[str] = None, visit_date: Optional[str] = None
				):
				anlambertUnsubmitted Not Done Inline Actions same here anlambert: same here
	"""Mercurial repository loading			"""Mercurial repository loading

	Import a mercurial tarball into swh.			Import a mercurial tarball into swh.

	Args: see :func:`DepositLoader.load`.			Args: see :func:`HgLoaderFromDisk` constructor.

	"""			"""
	loader = HgLoaderFromDisk(url, directory=directory, visit_date=visit_date)			loader = HgLoaderFromDisk.from_configfile(
				url=url, directory=directory, visit_date=parse_visit_date(visit_date)
				)
	return loader.load()			return loader.load()


	@shared_task(name=__name__ + ".LoadArchiveMercurialFromDisk")			@shared_task(name=__name__ + ".LoadArchiveMercurialFromDisk")
	def load_hg_from_archive(*, url, archive_path=None, visit_date=None):			def load_hg_from_archive(
				*, url: str, archive_path: Optional[str] = None, visit_date: Optional[str] = None
				):
				anlambertUnsubmitted Not Done Inline Actions same here anlambert: same here
	"""Import a mercurial tarball into swh.			"""Import a mercurial tarball into swh.

	Args: see :func:`DepositLoader.load`.			Args: see :func:`HgArchiveLoaderFromDisk` constructor.
	"""			"""
	loader = HgArchiveLoaderFromDisk(			loader = HgArchiveLoaderFromDisk.from_configfile(
	url, archive_path=archive_path, visit_date=visit_date			url=url, archive_path=archive_path, visit_date=parse_visit_date(visit_date)
	)			)
	return loader.load()			return loader.load()