flowchart TD
  A["Input: prepared_tasks, dm_queue, assigned_flag, user, project"] --> B

  subgraph Build candidate pool not_solved_tasks
    B[Start from prepared_tasks] --> B1[Exclude tasks annotated by this user]
    B1 --> B2[Exclude user's postponed drafts]
    B2 --> B3{assigned_flag?}
    B3 -- yes --> B5[Skip agreement logic] --> B7

    B3 -- no --> B4{"LSE low-agreement path?
fflag OPTIC-161
agreement_threshold set
user is annotator"}
    B4 -- yes --> B6["Filter by agreement threshold
and annotator capacity"] --> B7[Optionally prioritize by low agreement]

    B4 -- no --> B8{"Evaluation mode?
fflag ALL-LEAP-1825
annotator_evaluation_enabled"}
    B8 -- yes --> B7
    B8 -- no --> B9[Filter: is_labeled=false] --> B7
  end

  B7 --> C{dm_queue?}
  C -- yes --> DM["Data manager queue
not_solved_tasks.first()"] --> K
  C -- no --> D

  subgraph No DM queue path
    D{assigned_flag?} -- yes --> M["Manually assigned queue
first() from not_solved_tasks"] --> K
    D -- no --> E["Check existing lock for user
if exists: Task lock"] --> F

    F{prioritized_low_agreement?} -- yes --> LAL["Low agreement queue
first unlocked"] --> K
    F -- no --> G

    G{"GT-first gating?
should_attempt_ground_truth_first(user, project)"} -- yes --> GT["Onboarding ground truth queue
_try_onboarding_ground_truth()"] --> H
    G -- no --> H

    H{project.maximum_annotations > 1?} -- yes --> BF["Breadth first queue
_try_breadth_first()"] --> I
    H -- no --> I

    I{"FF overlap-after?
fflag FIX-BACK-LSDV-4523 AND show_overlap_first
AND no next_task"}
    I -- yes --> OF["Filter to overlap>1
Show overlap first"] --> S
    I -- no --> S

    S{next_task selected?}
    S -- yes --> P[Check post-queues]
    S -- no --> T{project.sampling}
    T -- Sequence --> SQ["Sequence queue
first unlocked"] --> P
    T -- Uncertainty --> AL["Active learning or random queue"] --> P
    T -- Uniform --> UR["Uniform random queue
random unlocked"] --> P
  end

  subgraph Post queues user-specific
    P --> PD["Postponed draft queue
user drafts: was_postponed=true, is_labeled=false"] --> SK
    SK["Skipped queue (REQUEUE_FOR_ME)
user annotations: was_cancelled=true, is_labeled=false"] --> K
  end

  K["Finalize
- Set task lock if required
- add_stream_history()
- return next_task + queue_info"]