pub async fn open_chain_state_db( work_dir: &Path, subtask_index: u32, ) -> StreamResult<Arc<dyn StateStore>>