Function plan_sql_distributed_with_id 

pub async fn plan_sql_distributed_with_id(
    sql: &str,
    catalog: &PlanningTableCatalog,
    query_id: QueryId,
    locator: &dyn TabletLocator,
    metadata: &dyn ClusterMetadata,
) -> DistributedResult<DistributedPlan>

Same as plan_sql_distributed but stamps a caller-chosen query id.