Function provision_root_tasks

shared/utils/task/task_new.py:6–42

(session,
                         job,
                         mode = 'default',
                         default_assignee = None,
                         default_reviewers = [])

def provision_root_tasks(session,
                         job,
                         mode = 'default',
                         default_assignee = None,
                         default_reviewers = []):
    if not job:
        return False

    if mode == 'default':
        directory_id = job.directory_id

    # TODO clarify image / video file types
    file_list = WorkingDirFileLink.file_list(
        session = session,
        working_dir_id = directory_id,
        limit = None,
        order_by_class_and_attribute = File.input_id
    )

    review_frequncy = None

    session.add(job)
    job.stat_count_tasks = 0

    for index, file in enumerate(file_list):

        root_task = root_task_new(session = session,
                                  job = job,
                                  file = file,
                                  guide_id = job.guide_default_id)
        if default_assignee:
            root_task.add_assignee(session = session, user = default_assignee)
        if default_reviewers:
            for reviewer in default_reviewers:
                root_task.add_reviewer(session, reviewer)

    return True


def root_task_new(session,