Changeset View
Changeset View
Standalone View
Standalone View
swh/deposit/signals.py
Show First 20 Lines • Show All 88 Lines • ▼ Show 20 Lines | if (instance.status == DEPOSIT_STATUS_DEPOSITED and | ||||
deposit_check_url=check_url) | deposit_check_url=check_url) | ||||
check_task_id = schedule_task(default_config.scheduler, task) | check_task_id = schedule_task(default_config.scheduler, task) | ||||
instance.check_task_id = check_task_id | instance.check_task_id = check_task_id | ||||
instance.save() | instance.save() | ||||
elif (instance.status == DEPOSIT_STATUS_VERIFIED and | elif (instance.status == DEPOSIT_STATUS_VERIFIED and | ||||
not instance.load_task_id): | not instance.load_task_id): | ||||
version = default_config.config.get('loader-version', 1) | |||||
# schedule deposit loading | |||||
if int(version) == 1: # default version | |||||
from swh.deposit.config import PRIVATE_GET_RAW_CONTENT | |||||
from swh.deposit.config import PRIVATE_GET_DEPOSIT_METADATA | |||||
from swh.deposit.config import PRIVATE_PUT_DEPOSIT | |||||
archive_url = reverse(PRIVATE_GET_RAW_CONTENT, args=args) | |||||
meta_url = reverse(PRIVATE_GET_DEPOSIT_METADATA, args=args) | |||||
update_url = reverse(PRIVATE_PUT_DEPOSIT, args=args) | |||||
task = create_oneshot_task_dict('load-deposit', | |||||
archive_url=archive_url, | |||||
deposit_meta_url=meta_url, | |||||
deposit_update_url=update_url) | |||||
else: # new version | |||||
url = utils.origin_url_from(instance) | url = utils.origin_url_from(instance) | ||||
task = create_oneshot_task_dict( | task = create_oneshot_task_dict( | ||||
'load-deposit', | 'load-deposit', | ||||
url=url, deposit_id=instance.id) | url=url, deposit_id=instance.id) | ||||
load_task_id = schedule_task(default_config.scheduler, task) | load_task_id = schedule_task(default_config.scheduler, task) | ||||
instance.load_task_id = load_task_id | instance.load_task_id = load_task_id | ||||
instance.save() | instance.save() |