Optimize worker_id retrieval in CreateStreamingJobCommandInfo

risingwavelabs · Jul 23, 2024 · f3f2d95 · f3f2d95
1 parent dbe51b5
commit f3f2d95
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/meta/src/barrier/command.rs b/src/meta/src/barrier/command.rs
@@ -174,9 +174,7 @@ impl CreateStreamingJobCommandInfo {
                                     .actor_status
                                     .get(&actor.actor_id)
                                     .expect("should exist")
-                                    .get_parallel_unit()
-                                    .expect("should set")
-                                    .worker_node_id,
+                                    .worker_id(),
                             )
                         })
                         .collect(),