提交 7e863578 编写于 作者: W Wang Xiangyu

solve conflicts

Signed-off-by: NWang Xiangyu <xy.wang@zilliz.com>
---
name: "Enhancement request"
about: Suggest an enhancement idea for Milvus
title: ''
labels: ''
assignees: ''
---
**Please state your issue using the following template and, most importantly, in English.**
**What would you like to be added ?**
**Why is this needed ?**
...@@ -97,6 +97,7 @@ pipeline { ...@@ -97,6 +97,7 @@ pipeline {
TARGET_REPO = "${params.DOKCER_REGISTRY_URL}/milvus/engine" TARGET_REPO = "${params.DOKCER_REGISTRY_URL}/milvus/engine"
SOURCE_TAG = "${CHANGE_TARGET ? CHANGE_TARGET : SEMVER}-${BINARY_VERSION}-${OS_NAME}-${LOWER_BUILD_TYPE}" SOURCE_TAG = "${CHANGE_TARGET ? CHANGE_TARGET : SEMVER}-${BINARY_VERSION}-${OS_NAME}-${LOWER_BUILD_TYPE}"
TARGET_TAG = "${SEMVER}-${BINARY_VERSION}-${OS_NAME}-${LOWER_BUILD_TYPE}" TARGET_TAG = "${SEMVER}-${BINARY_VERSION}-${OS_NAME}-${LOWER_BUILD_TYPE}"
DOCKER_BUILDKIT = 1
} }
agent { agent {
kubernetes { kubernetes {
......
...@@ -217,6 +217,8 @@ Resource::executor_function() { ...@@ -217,6 +217,8 @@ Resource::executor_function() {
ResMgrInst::GetInstance()->GetResource("disk")->WakeupLoader(); ResMgrInst::GetInstance()->GetResource("disk")->WakeupLoader();
} }
task_item->task = FinishedTask::Create(task_item->task);
if (subscriber_) { if (subscriber_) {
auto event = std::make_shared<FinishTaskEvent>(shared_from_this(), task_item); auto event = std::make_shared<FinishTaskEvent>(shared_from_this(), task_item);
subscriber_(std::static_pointer_cast<Event>(event)); subscriber_(std::static_pointer_cast<Event>(event));
......
...@@ -14,11 +14,14 @@ ...@@ -14,11 +14,14 @@
namespace milvus::scheduler { namespace milvus::scheduler {
std::shared_ptr<FinishedTask> std::shared_ptr<FinishedTask>
FinishedTask::Create() { FinishedTask::Create(const TaskPtr& task) {
return std::make_shared<FinishedTask>(); return std::make_shared<FinishedTask>(task);
} }
FinishedTask::FinishedTask() : Task(TaskType::SearchTask, nullptr) { FinishedTask::FinishedTask(const TaskPtr& task) : Task(TaskType::SearchTask, nullptr) {
Task::task_path_ = task->task_path_;
Task::type_ = task->type_;
Task::label_ = task->label_;
} }
Status Status
......
...@@ -20,10 +20,10 @@ namespace milvus::scheduler { ...@@ -20,10 +20,10 @@ namespace milvus::scheduler {
class FinishedTask : public Task { class FinishedTask : public Task {
public: public:
static std::shared_ptr<FinishedTask> static std::shared_ptr<FinishedTask>
Create(); Create(const TaskPtr& task);
public: public:
FinishedTask(); explicit FinishedTask(const TaskPtr& task);
Status Status
OnLoad(LoadType type, uint8_t device_id) override; OnLoad(LoadType type, uint8_t device_id) override;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册