Page MenuHomeSoftware Heritage
Files F7066462

D266.id900.diff
No OneTemporary
Actions

D266.id900.diff
View Options

diff --git a/swh/loader/core/loader.py b/swh/loader/core/loader.py
--- a/swh/loader/core/loader.py
+++ b/swh/loader/core/loader.py
@@ -237,6 +237,37 @@
return origin_visit
@retry(retry_on_exception=retry_loading, stop_max_attempt_number=3)
+ def send_origin_metadata(self, origin_id, visit_date, provider,
+ tool, metadata):
+ log_id = str(uuid.uuid4())
+ self.log.debug(
+ """Creating origin_metadata for origin %s at time %s with provider
+ %s and tool %s""" % (
+ origin_id, visit_date, provider, tool),
+ extra={
+ 'swh_type': 'storage_send_start',
+ 'swh_content_type': 'origin_metadata',
+ 'swh_num': 1,
+ 'swh_id': log_id
+ })
+
+ self.storage.origin_metadata_add(origin_id,
+ visit_date,
+ provider,
+ tool,
+ metadata)
+ self.log.debug(
+ """Done Creating origin_metadata for origin %s at time %s with
+ provider %s and tool %s""" % (
+ origin_id, visit_date, provider, tool),
+ extra={
+ 'swh_type': 'storage_send_end',
+ 'swh_content_type': 'origin_metadata',
+ 'swh_num': 1,
+ 'swh_id': log_id
+ })
+
+ @retry(retry_on_exception=retry_loading, stop_max_attempt_number=3)
def update_origin_visit(self, origin_id, visit, status):
log_id = str(uuid.uuid4())
self.log.debug(
@@ -666,6 +697,13 @@
"""
pass
+ def store_metadata(self):
+ """Store fetched metadata in the database.
+
+ For more information, see implementation in :class:`DepositLoader`.
+ """
+ pass
+
def load_status(self):
"""Detailed loading status.
@@ -743,6 +781,7 @@
if not more_data_to_fetch:
break
+ self.store_metadata()
self.close_fetch_history_success(fetch_history_id)
self.update_origin_visit(
self.origin_id, self.visit, status=self.visit_status())

File Metadata

Mime Type
text/plain
Expires
Nov 5 2024, 10:24 AM (18 w, 5 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3218107

Event Timeline

About · Developer information · Legal