risingwave_meta::controller::streaming_job

Function update_connector_props_fragments

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