pub async fn create_source_worker_handle(
source: &Source,
metrics: Arc<MetaMetrics>,
) -> MetaResult<ConnectorSourceWorkerHandle>
Expand description
Used to create a new ConnectorSourceWorkerHandle
for a new source.
It will call ConnectorSourceWorker::tick()
to fetch split metadata once before returning.