[Core] Fix a bug where we submit the actor creation task to the wrong…

… submitter (#47109) Signed-off-by: Jiajun Yao <[email protected]>
ray-project · Aug 13, 2024 · 51963ba · 51963ba
1 parent ba9db6b
commit 51963ba
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/ray/core_worker/core_worker.cc b/src/ray/core_worker/core_worker.cc
@@ -450,6 +450,7 @@ CoreWorker::CoreWorker(const CoreWorkerOptions &options, const WorkerID &worker_
             }
             RAY_CHECK_OK(actor_task_submitter_->SubmitTask(spec));
           } else {
+            RAY_CHECK(spec.IsNormalTask());
             RAY_CHECK_OK(normal_task_submitter_->SubmitTask(spec));
           }
         }
@@ -1075,6 +1076,8 @@ void CoreWorker::InternalHeartbeat() {
         actor_handle->SetResubmittedActorTaskSpec(spec);
       }
       RAY_CHECK_OK(actor_task_submitter_->SubmitTask(spec));
+    } else if (spec.IsActorCreationTask()) {
+      RAY_CHECK_OK(actor_task_submitter_->SubmitActorCreationTask(spec));
     } else {
       RAY_CHECK_OK(normal_task_submitter_->SubmitTask(spec));
     }