Function job_resync_api

default/methods/task/task_template/job_resync.py:10–47

Checks for any missing files on the job's datasets and sends a resync signal to create task in case of missing files. :return: http response

(project_string_id)

              methods = ['POST'])
@Project_permissions.user_has_project(Roles = ["admin", "Editor"], apis_user_list = ["api_enabled_builder"])
def job_resync_api(project_string_id):
    """
        Checks for any missing files on the job's datasets
        and sends a resync signal to create task
        in case of missing files.
    :return: http response
    """

    spec_list = [
        {"task_template_id": {
            'required': True,
            'kind': int
        }},
    ]

    log, input, untrusted_input = regular_input.master(request = request,
                                                       spec_list = spec_list)
    if len(log["error"].keys()) >= 1:
        return jsonify(log = log), 400

    with sessionMaker.session_scope() as session:
        user = User.get(session)
        project = Project.get_by_string_id(session = session, project_string_id = project_string_id)
        if user:
            member = user.member
        else:
            client_id = request.authorization.get('username', None)
            auth = Auth_api.get(session, client_id)
            member = auth.member

        resync_result, log = job_resync_core(session = session,
                                             project = project,
                                             member = member,
                                             task_template_id = input['task_template_id'],
                                             log = log)
        if len(log["error"].keys()) >= 1:
            return jsonify(log = log), 400
        return jsonify(resync_result = resync_result, log = log), 200


def job_resync_core(session,