Review queue operations
Review queues assign items (traces) to reviewers and collect structured feedback (MLflow 3.14+).
MLFlowClient.createreviewqueue — Function
createreviewqueue(instance::MLFlow, experiment_id::String, name::String,
queue_type::String; created_by::Union{String,Missing}=missing,
users::Union{Array{String},Missing}=missing,
schema_ids::Union{Array{String},Missing}=missing)Create a ReviewQueue (user or custom) scoped to an experiment.
Arguments
instance:MLFlowconfiguration.experiment_id: Parent experiment ID.name: Queue name (must be unique within the experiment).queue_type: Queue type (USERorCUSTOM, seeReviewQueueType). A USER queue must have exactly one user equal to its name and no schemas; a CUSTOM queue may not use the reserved namedefault.created_by: Optional owner of the queue (server-stamped on authenticated servers).users: Optional assigned-user pool.schema_ids: Optional attached label-schema IDs (for a CUSTOM queue).
Returns
An instance of type ReviewQueue.
MLFlowClient.getorcreateuserqueue — Function
getorcreateuserqueue(instance::MLFlow, experiment_id::String, user::String;
created_by::Union{String,Missing}=missing)Get-or-create a user's personal ReviewQueue for an experiment. This operation is atomic and idempotent on (experiment_id, user).
Arguments
instance:MLFlowconfiguration.experiment_id: Parent experiment ID.user: The user identifier whose personal queue to get or create.created_by: Optional owner of the queue.
Returns
An instance of type ReviewQueue.
MLFlowClient.getreviewqueue — Function
getreviewqueue(instance::MLFlow, queue_id::String)Get a ReviewQueue by ID.
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.
Returns
An instance of type ReviewQueue.
MLFlowClient.getreviewqueuebyname — Function
getreviewqueuebyname(instance::MLFlow, experiment_id::String, name::String)Get a ReviewQueue by (experiment_id, name).
Arguments
instance:MLFlowconfiguration.experiment_id: Parent experiment ID.name: The review queue name.
Returns
An instance of type ReviewQueue.
MLFlowClient.listreviewqueues — Function
listreviewqueues(instance::MLFlow, experiment_id::String;
user::Union{String,Missing}=missing, item_id::Union{String,Missing}=missing,
max_results::Union{Int,Missing}=missing,
page_token::Union{String,Missing}=missing)List an experiment's ReviewQueue entities, newest first.
Arguments
instance:MLFlowconfiguration.experiment_id: Parent experiment ID.user: If set, return only queues that user is assigned to.item_id: If set, return only queues that already contain this item (a trace ID).max_results: Maximum number of queues to return.page_token: Token indicating the page of queues to fetch.
Returns
- Vector of
ReviewQueueentities. - The next page token if there are more results.
MLFlowClient.updatereviewqueue — Function
updatereviewqueue(instance::MLFlow, queue_id::String;
name::Union{String,Missing}=missing,
users::Union{Array{String},Missing}=missing,
schema_ids::Union{Array{String},Missing}=missing,
new_owner::Union{String,Missing}=missing)Update a CUSTOM ReviewQueue's name, assigned users, attached schemas, and/or owner. The queue_type is immutable and USER queues reject this operation. Passing users or schema_ids replaces the corresponding set (passing an empty vector clears it).
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.name: Optional new queue name.users: Optional replacement assigned-user pool.schema_ids: Optional replacement attached label-schema IDs.new_owner: Optional new owner (reassignscreated_by; requires MANAGE permission).
Returns
An instance of type ReviewQueue.
MLFlowClient.deletereviewqueue — Function
deletereviewqueue(instance::MLFlow, queue_id::String)Delete a ReviewQueue and its user/item/schema associations. This is a no-op if the queue does not exist.
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.
Returns
true if successful. Otherwise, raises exception.
MLFlowClient.additemstoreviewqueue — Function
additemstoreviewqueue(instance::MLFlow, queue_id::String, item_ids::Array{String};
item_type::String="TRACE")Attach items to a ReviewQueue. This is idempotent per item (re-attaching preserves the existing status).
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.item_ids: IDs of the items to attach (trace IDs in v1).item_type: Type of the referenced objects (seeReviewItemType); defaults toTRACE, the only supported value.
Returns
Vector of ReviewQueueItem covering every requested item, in request order.
MLFlowClient.removeitemsfromreviewqueue — Function
removeitemsfromreviewqueue(instance::MLFlow, queue_id::String, item_ids::Array{String})Detach items from a ReviewQueue. This is a no-op for items that are not attached.
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.item_ids: IDs of the items to detach.
Returns
true if successful. Otherwise, raises exception.
MLFlowClient.listreviewqueueitems — Function
listreviewqueueitems(instance::MLFlow, queue_id::String;
status::Union{String,Missing}=missing,
max_results::Union{Int,Missing}=missing,
page_token::Union{String,Missing}=missing)List a ReviewQueue's attached items, newest-attached first.
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.status: Optional filter by status (seeReviewStatus).max_results: Maximum number of items to return.page_token: Token indicating the page of items to fetch.
Returns
- Vector of
ReviewQueueItementities. - The next page token if there are more results.
MLFlowClient.setreviewqueueitemstatus — Function
setreviewqueueitemstatus(instance::MLFlow, queue_id::String, item_id::String,
status::String; completed_by::Union{String,Missing}=missing)Set the shared-pool status of an attached ReviewQueueItem.
Arguments
instance:MLFlowconfiguration.queue_id: The review queue ID.item_id: The item ID.status: New status (seeReviewStatus).completed_by: Required forCOMPLETE/DECLINED; must be absent forPENDING(reopening an item clears attribution).
Returns
An instance of type ReviewQueueItem.