risingwave_meta::controller::streaming_job

Function update_connector_props_fragments

Source 
async fn update_connector_props_fragments<F>(
    txn: &DatabaseTransaction,
    job_id: i32,
    expect_flag: FragmentTypeFlag,
    alter_stream_node_fn: F,
) -> MetaResult<()>
where
    F: FnMut(&mut PbNodeBody, &mut bool),