Changeset View

Standalone View

Show First 20 Lines • Show All 603 Lines • ▼ Show 20 Lines	Returns:
:func:`swh.web.common.origin_save.create_save_origin_request`		:func:`swh.web.common.origin_save.create_save_origin_request`

"""		"""
task_ids = []		task_ids = []
for sor in requests_queryset:		for sor in requests_queryset:
task_ids.append(sor.loading_task_id)		task_ids.append(sor.loading_task_id)
save_requests = []		save_requests = []
if task_ids:		if task_ids:
		try:
tasks = scheduler().get_tasks(task_ids)		tasks = scheduler().get_tasks(task_ids)
tasks = {task["id"]: task for task in tasks}		tasks = {task["id"]: task for task in tasks}
task_runs = scheduler().get_task_runs(tasks)		task_runs = scheduler().get_task_runs(tasks)
task_runs = {task_run["task"]: task_run for task_run in task_runs}		task_runs = {task_run["task"]: task_run for task_run in task_runs}
		except Exception:
		# allow to avoid mocking api GET responses for /origin/save endpoint when
		# running cypress tests as scheduler is not available
		tasks = {}
		task_runs = {}
for sor in requests_queryset:		for sor in requests_queryset:
sr_dict = _update_save_request_info(		sr_dict = _update_save_request_info(
sor, tasks.get(sor.loading_task_id), task_runs.get(sor.loading_task_id),		sor, tasks.get(sor.loading_task_id), task_runs.get(sor.loading_task_id),
)		)
save_requests.append(sr_dict)		save_requests.append(sr_dict)
return save_requests		return save_requests


▲ Show 20 Lines • Show All 295 Lines • Show Last 20 Lines