risingwave_meta::stream::source_manager::worker

Function create_source_worker_async

Source 
pub fn create_source_worker_async(
    source: Source,
    managed_sources: &mut HashMap<SourceId, ConnectorSourceWorkerHandle>,
    metrics: Arc<MetaMetrics>,
) -> MetaResult<()>
Expand description

Used on startup (SourceManager::new). Failed sources will not block meta startup.