Support async parameter in Job APIs.

This commit is contained in:
sdk-team
2022-12-07 08:55:04 +00:00
parent 7a780263d7
commit b1800ef54d
11 changed files with 73 additions and 1 deletions

View File

@@ -1 +1 @@
1.36.1377
1.36.1378

View File

@@ -42,6 +42,8 @@ public:
void setContent(const std::string &content);
std::string getAccessKeyId() const;
void setAccessKeyId(const std::string &accessKeyId);
bool getAsync() const;
void setAsync(bool async);
private:
std::string targetFile_;
@@ -50,6 +52,7 @@ private:
std::string clusterId_;
std::string content_;
std::string accessKeyId_;
bool async_;
};
} // namespace Model
} // namespace EHPC

View File

@@ -36,11 +36,14 @@ public:
void setClusterId(const std::string &clusterId);
std::string getAccessKeyId() const;
void setAccessKeyId(const std::string &accessKeyId);
bool getAsync() const;
void setAsync(bool async);
private:
std::string jobs_;
std::string clusterId_;
std::string accessKeyId_;
bool async_;
};
} // namespace Model
} // namespace EHPC

View File

@@ -36,11 +36,14 @@ public:
void setClusterId(const std::string &clusterId);
std::string getAccessKeyId() const;
void setAccessKeyId(const std::string &accessKeyId);
bool getAsync() const;
void setAsync(bool async);
private:
std::string jobs_;
std::string clusterId_;
std::string accessKeyId_;
bool async_;
};
} // namespace Model
} // namespace EHPC

View File

@@ -36,11 +36,14 @@ public:
void setClusterId(const std::string &clusterId);
std::string getAccessKeyId() const;
void setAccessKeyId(const std::string &accessKeyId);
bool getAsync() const;
void setAsync(bool async);
private:
std::string jobs_;
std::string clusterId_;
std::string accessKeyId_;
bool async_;
};
} // namespace Model
} // namespace EHPC

View File

@@ -58,6 +58,8 @@ public:
void setPostCmdLine(const std::string &postCmdLine);
std::string getRunasUser() const;
void setRunasUser(const std::string &runasUser);
int getCpu() const;
void setCpu(int cpu);
std::string getClusterId() const;
void setClusterId(const std::string &clusterId);
bool getReRunable() const;
@@ -70,6 +72,8 @@ public:
void setGpu(int gpu);
int getNode() const;
void setNode(int node);
bool getAsync() const;
void setAsync(bool async);
int getTask() const;
void setTask(int task);
std::string getInputFileUrl() const;
@@ -94,12 +98,14 @@ private:
std::string variables_;
std::string postCmdLine_;
std::string runasUser_;
int cpu_;
std::string clusterId_;
bool reRunable_;
int thread_;
int priority_;
int gpu_;
int node_;
bool async_;
int task_;
std::string inputFileUrl_;
std::string name_;

View File

@@ -79,3 +79,12 @@ void CreateJobFileRequest::setAccessKeyId(const std::string &accessKeyId) {
setParameter(std::string("AccessKeyId"), accessKeyId);
}
bool CreateJobFileRequest::getAsync() const {
return async_;
}
void CreateJobFileRequest::setAsync(bool async) {
async_ = async;
setParameter(std::string("Async"), async ? "true" : "false");
}

View File

@@ -52,3 +52,12 @@ void DeleteJobsRequest::setAccessKeyId(const std::string &accessKeyId) {
setParameter(std::string("AccessKeyId"), accessKeyId);
}
bool DeleteJobsRequest::getAsync() const {
return async_;
}
void DeleteJobsRequest::setAsync(bool async) {
async_ = async;
setParameter(std::string("Async"), async ? "true" : "false");
}

View File

@@ -52,3 +52,12 @@ void RerunJobsRequest::setAccessKeyId(const std::string &accessKeyId) {
setParameter(std::string("AccessKeyId"), accessKeyId);
}
bool RerunJobsRequest::getAsync() const {
return async_;
}
void RerunJobsRequest::setAsync(bool async) {
async_ = async;
setParameter(std::string("Async"), async ? "true" : "false");
}

View File

@@ -52,3 +52,12 @@ void StopJobsRequest::setAccessKeyId(const std::string &accessKeyId) {
setParameter(std::string("AccessKeyId"), accessKeyId);
}
bool StopJobsRequest::getAsync() const {
return async_;
}
void StopJobsRequest::setAsync(bool async) {
async_ = async;
setParameter(std::string("Async"), async ? "true" : "false");
}

View File

@@ -151,6 +151,15 @@ void SubmitJobRequest::setRunasUser(const std::string &runasUser) {
setParameter(std::string("RunasUser"), runasUser);
}
int SubmitJobRequest::getCpu() const {
return cpu_;
}
void SubmitJobRequest::setCpu(int cpu) {
cpu_ = cpu;
setParameter(std::string("Cpu"), std::to_string(cpu));
}
std::string SubmitJobRequest::getClusterId() const {
return clusterId_;
}
@@ -205,6 +214,15 @@ void SubmitJobRequest::setNode(int node) {
setParameter(std::string("Node"), std::to_string(node));
}
bool SubmitJobRequest::getAsync() const {
return async_;
}
void SubmitJobRequest::setAsync(bool async) {
async_ = async;
setParameter(std::string("Async"), async ? "true" : "false");
}
int SubmitJobRequest::getTask() const {
return task_;
}