Changeset View
Changeset View
Standalone View
Standalone View
swh/web/save_code_now/origin_save.py
Show First 20 Lines • Show All 508 Lines • ▼ Show 20 Lines | if save_request_status == SAVE_REQUEST_ACCEPTED: | ||||
# get the scheduler task and its status | # get the scheduler task and its status | ||||
tasks = scheduler().get_tasks([sor.loading_task_id]) | tasks = scheduler().get_tasks([sor.loading_task_id]) | ||||
task = tasks[0] if tasks else None | task = tasks[0] if tasks else None | ||||
task_runs = scheduler().get_task_runs([sor.loading_task_id]) | task_runs = scheduler().get_task_runs([sor.loading_task_id]) | ||||
task_run = task_runs[0] if task_runs else None | task_run = task_runs[0] if task_runs else None | ||||
save_request_info = _update_save_request_info(sor, task, task_run) | save_request_info = _update_save_request_info(sor, task, task_run) | ||||
task_status = save_request_info["save_task_status"] | task_status = save_request_info["save_task_status"] | ||||
# create a new scheduler task only if the previous one has been | # create a new scheduler task only if the previous one has been | ||||
# already executed | # already or is currently executed | ||||
if ( | if task_status in ( | ||||
task_status == SAVE_TASK_FAILED | SAVE_TASK_FAILED, | ||||
or task_status == SAVE_TASK_SUCCEEDED | SAVE_TASK_SUCCEEDED, | ||||
SAVE_TASK_RUNNING, | |||||
): | ): | ||||
can_create_task = True | can_create_task = True | ||||
sor = None | sor = None | ||||
else: | else: | ||||
can_create_task = False | can_create_task = False | ||||
if can_create_task: | if can_create_task: | ||||
# effectively create the scheduler task | # effectively create the scheduler task | ||||
▲ Show 20 Lines • Show All 310 Lines • Show Last 20 Lines |