Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
Jelmer Kuperus committed Dec 30, 2024
1 parent c128cdd commit df0406f
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -803,8 +803,6 @@ private[knn] abstract class KnnAlgorithm[TModel <: KnnModelBase[TModel]](overrid
val taskReqs = new TaskResourceRequests().cpus(numThreads)
val profile = new ResourceProfileBuilder().require(taskReqs).build()

val numReplicas = getNumReplicas

val indexRdd = partitionedIndexItems
.withResources(profile) // TODO JELMER is this the correct place ?
.mapPartitions(
Expand Down Expand Up @@ -859,7 +857,6 @@ private[knn] abstract class KnnAlgorithm[TModel <: KnnModelBase[TModel]](overrid

val registrations =
serve[TId, TVector, TItem, TDistance](modelUid, indexRdd, getNumPartitions, getNumReplicas, numThreads)
println(registrations) // TODO remove this

createModel[TId, TVector, TItem, TDistance](
modelUid,
Expand Down

0 comments on commit df0406f

Please sign in to comment.