risingwave_meta::controller::streaming_job

Function update_sink_fragment_props

Source 
async fn update_sink_fragment_props(
    txn: &DatabaseTransaction,
    sink_id: SinkId,
    props: BTreeMap<String, String>,
) -> MetaResult<()>