async fn run_replica_core<T>(__arg0: ReplicaTaskConfig<T>) -> Result<(), Error>where
    T: Timestamp + Lattice,
    ComputeGrpcClient: ComputeClient<T>,