lint

s0nskar · s0nskar · commit 710c9134148b · 2026-06-26T19:57:44.000+05:30
diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala
@@ -63,7 +63,7 @@ class TagsManager(configService: Option[ConfigService]) extends Logging {
     val workerTagsPredicate = new Predicate[WorkerInfo] {
       override def test(w: WorkerInfo): Boolean = tags.forall { tag =>
         w.tags.contains(tag) ||
-          store.flatMap(s => Option(s.get(tag))).exists(_.contains(w.toUniqueId))
+        store.flatMap(s => Option(s.get(tag))).exists(_.contains(w.toUniqueId))
       }
     }
     workers.stream().filter(workerTagsPredicate).collect(Collectors.toList())

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ class TagsManager(configService: Option[ConfigService]) extends Logging {`
`63`	`63`	`val workerTagsPredicate = new Predicate[WorkerInfo] {`
`64`	`64`	`override def test(w: WorkerInfo): Boolean = tags.forall { tag =>`
`65`	`65`	`w.tags.contains(tag) \|\|`
`66`		`- store.flatMap(s => Option(s.get(tag))).exists(_.contains(w.toUniqueId))`
	`66`	`+ store.flatMap(s => Option(s.get(tag))).exists(_.contains(w.toUniqueId))`
`67`	`67`	`}`
`68`	`68`	`}`
`69`	`69`	`workers.stream().filter(workerTagsPredicate).collect(Collectors.toList())`