Function create_source_worker 

pub async fn create_source_worker(
    source: &Source,
    metrics: Arc<MetaMetrics>,
) -> MetaResult<ConnectorSourceWorkerHandle>

Used to create a new ConnectorSourceWorkerHandle for a new source.

It will call ConnectorSourceWorker::tick() to fetch split metadata once before returning.