Skip to content

Commit

Permalink
log add job
Browse files Browse the repository at this point in the history
  • Loading branch information
pengweisong committed Jan 10, 2023
1 parent aad0b77 commit 5facfbc
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/meta/processors/job/JobManager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -567,8 +567,13 @@ nebula::cpp2::ErrorCode JobManager::addJob(JobDescription jobDesc) {
if (rc == nebula::cpp2::ErrorCode::SUCCEEDED) {
enqueue(spaceId, jobId, JbOp::ADD, jobDesc.getJobType());
inFlightJobs_.emplace(std::move(jobId), std::move(jobDesc));
LOG(INFO) << folly::sformat("Add job successfully, job id={}, job type={}",
jobId,
apache::thrift::util::enumNameSafe(jobDesc.getJobType()));
} else {
LOG(INFO) << "Add Job Failed";
LOG(INFO) << folly::sformat("Add job failed, job id={}, job type={}",
jobId,
apache::thrift::util::enumNameSafe(jobDesc.getJobType()));
if (rc != nebula::cpp2::ErrorCode::E_LEADER_CHANGED) {
rc = nebula::cpp2::ErrorCode::E_ADD_JOB_FAILURE;
}
Expand Down

0 comments on commit 5facfbc

Please sign in to comment.