Changeset View
Changeset View
Standalone View
Standalone View
swh/deposit/migrations/0018_migrate_swhids.py
| Show First 20 Lines • Show All 247 Lines • ▼ Show 20 Lines | ): | ||||
| assert deposit.swh_id is not None | assert deposit.swh_id is not None | ||||
| assert deposit.swh_id_context is None | assert deposit.swh_id_context is None | ||||
| assert deposit.swh_anchor_id is None | assert deposit.swh_anchor_id is None | ||||
| assert deposit.swh_anchor_id_context is None | assert deposit.swh_anchor_id_context is None | ||||
| rev_id = obj_rev.object_id | rev_id = obj_rev.object_id | ||||
| rev_id_bytes = hash_to_bytes(rev_id) | rev_id_bytes = hash_to_bytes(rev_id) | ||||
| revisions = list(storage.revision_get([rev_id_bytes])) | revision = storage.revision_get([rev_id_bytes])[0] | ||||
| if not revisions: | if not revision: | ||||
| logger.warning("Deposit id %s: Revision %s not found!", deposit.id, rev_id) | logger.warning("Deposit id %s: Revision %s not found!", deposit.id, rev_id) | ||||
| continue | continue | ||||
| revision = revisions[0] | |||||
| provider_url = deposit.client.provider_url | provider_url = deposit.client.provider_url | ||||
| external_id = deposit.external_id | external_id = deposit.external_id | ||||
| origin = resolve_origin(deposit.id, provider_url, external_id) | origin = resolve_origin(deposit.id, provider_url, external_id) | ||||
| check_origin = storage.origin_get([origin])[0] | check_origin = storage.origin_get([origin])[0] | ||||
| if not check_origin: | if not check_origin: | ||||
| logger.warning("Deposit id %s: Origin %s not found!", deposit.id, origin) | logger.warning("Deposit id %s: Origin %s not found!", deposit.id, origin) | ||||
| ▲ Show 20 Lines • Show All 81 Lines • Show Last 20 Lines | |||||