async fn spawn_flush(
flush: FlushBatch,
partition_manager: PartitionRuleManagerRef,
node_manager: NodeManagerRef,
catalog_manager: CatalogManagerRef,
flow_notification_tx: Sender<FlowNotification>,
semaphore: Arc<Semaphore>,
)