Function _fairness_headers

workers/file_processing/structure_tool_task.py:43–60

Fairness header for executor dispatches. Structure-tool dispatches are workflow-execution work — both ETL and API workflows route through here. ``NON_API`` is the safe default (API traffic preempting is a strictly weaker mistake than the inverse). TODO(UN-3504): propagate the c

(
    organization_id: str,
)

def _fairness_headers(
    organization_id: str,
) -> dict[str, dict[str, str | int | None]]:
    """Fairness header for executor dispatches.

    Structure-tool dispatches are workflow-execution work — both ETL
    and API workflows route through here. ``NON_API`` is the safe
    default (API traffic preempting is a strictly weaker mistake than
    the inverse).

    TODO(UN-3504): propagate the caller's WorkloadType (API vs ETL)
    instead of hard-coding ``NON_API``. Requires the chord-lift work
    so the workflow type flows from the chord caller down to here.
    """
    return FairnessKey(
        org_id=organization_id,
        workload_type=WorkloadType.NON_API,
    ).as_header()


# -----------------------------------------------------------------------