Skip to content

Commit

Permalink
[core] [easy] [no-op] Fix util filename naming (#49579)
Browse files Browse the repository at this point in the history
Signed-off-by: dentiny <dentinyhao@gmail.com>
  • Loading branch information
dentiny authored Jan 5, 2025
1 parent d0b0575 commit 951fc14
Show file tree
Hide file tree
Showing 6 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/ray/core_worker/transport/actor_scheduling_queue.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,9 @@
#include "ray/common/task/task_spec.h"
#include "ray/core_worker/fiber.h"
#include "ray/core_worker/task_event_buffer.h"
#include "ray/core_worker/transport/actor_scheduling_util.h"
#include "ray/core_worker/transport/concurrency_group_manager.h"
#include "ray/core_worker/transport/scheduling_queue.h"
#include "ray/core_worker/transport/scheduling_util.h"
#include "ray/core_worker/transport/thread_pool.h"
#include "ray/raylet_client/raylet_client.h"
#include "ray/rpc/server_call.h"
Expand Down
2 changes: 1 addition & 1 deletion src/ray/core_worker/transport/normal_scheduling_queue.cc
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ void NormalSchedulingQueue::ScheduleRequests() {
{
absl::MutexLock lock(&mu_);
if (!pending_normal_tasks_.empty()) {
head = pending_normal_tasks_.front();
head = std::move(pending_normal_tasks_.front());
pending_normal_tasks_.pop_front();
} else {
return;
Expand Down
2 changes: 1 addition & 1 deletion src/ray/core_worker/transport/normal_scheduling_queue.h
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@
#include "absl/synchronization/mutex.h"
#include "ray/common/id.h"
#include "ray/common/task/task_spec.h"
#include "ray/core_worker/transport/actor_scheduling_util.h"
#include "ray/core_worker/transport/scheduling_queue.h"
#include "ray/core_worker/transport/scheduling_util.h"
#include "ray/raylet_client/raylet_client.h"
#include "ray/rpc/server_call.h"
#include "src/ray/protobuf/core_worker.pb.h"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,9 @@
#include "ray/common/task/task_spec.h"
#include "ray/core_worker/fiber.h"
#include "ray/core_worker/task_event_buffer.h"
#include "ray/core_worker/transport/actor_scheduling_util.h"
#include "ray/core_worker/transport/concurrency_group_manager.h"
#include "ray/core_worker/transport/scheduling_queue.h"
#include "ray/core_worker/transport/scheduling_util.h"
#include "ray/core_worker/transport/thread_pool.h"
#include "ray/raylet_client/raylet_client.h"
#include "ray/rpc/server_call.h"
Expand Down

0 comments on commit 951fc14

Please sign in to comment.