Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in
Toggle navigation
C
cromwell-sdk
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
liugaoling
cromwell-sdk
Commits
d5ebc1a0
Commit
d5ebc1a0
authored
Jun 13, 2022
by
liugaoling
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
add params
parent
549ae5f6
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
29 additions
and
3 deletions
+29
-3
CloudamURL.java
src/main/java/com/cloudam/cromwell/constant/CloudamURL.java
+1
-1
CreateJobRequest.java
...main/java/com/cloudam/cromwell/core/CreateJobRequest.java
+2
-2
JobDescription.java
...main/java/com/cloudam/cromwell/domain/JobDescription.java
+26
-0
No files found.
src/main/java/com/cloudam/cromwell/constant/CloudamURL.java
View file @
d5ebc1a0
...
@@ -10,7 +10,7 @@ public interface CloudamURL {
...
@@ -10,7 +10,7 @@ public interface CloudamURL {
String
AUTH_URL_SUFFIX
=
"uaa/users/current"
;
String
AUTH_URL_SUFFIX
=
"uaa/users/current"
;
String
CREATE_JOB_URL_SUFFIX
=
"c3ce/cloud-bursting/job"
;
String
CREATE_JOB_URL_SUFFIX
=
"c3ce/cloud-bursting/job
/workflow
"
;
String
GET_JOB_URL_SUFFIX
=
"c3ce/cloud-bursting/job/workflow"
;
String
GET_JOB_URL_SUFFIX
=
"c3ce/cloud-bursting/job/workflow"
;
...
...
src/main/java/com/cloudam/cromwell/core/CreateJobRequest.java
View file @
d5ebc1a0
...
@@ -55,8 +55,8 @@ public class CreateJobRequest extends CloudamRequest<CreateJobResponse> {
...
@@ -55,8 +55,8 @@ public class CreateJobRequest extends CloudamRequest<CreateJobResponse> {
jsonObject
.
put
(
"zoneId"
,
jobDescription
.
getZoneId
());
jsonObject
.
put
(
"zoneId"
,
jobDescription
.
getZoneId
());
jsonObject
.
put
(
"os"
,
jobDescription
.
getAutoCluster
().
getOs
());
jsonObject
.
put
(
"os"
,
jobDescription
.
getAutoCluster
().
getOs
());
jsonObject
.
put
(
"slurmCommand"
,
Base64
.
getEncoder
().
encodeToString
(
buildSbatchSubmit
(
jobDescription
).
getBytes
()));
jsonObject
.
put
(
"slurmCommand"
,
Base64
.
getEncoder
().
encodeToString
(
buildSbatchSubmit
(
jobDescription
).
getBytes
()));
jsonObject
.
put
(
"
masterId"
,
jobDescription
.
getProject
Id
());
jsonObject
.
put
(
"
workflowJobId"
,
jobDescription
.
getWorkflowJob
Id
());
System
.
out
.
println
(
jsonObject
.
toJSONString
());
jsonObject
.
put
(
"username"
,
jobDescription
.
getUsername
());
return
jsonObject
;
return
jsonObject
;
}
}
...
...
src/main/java/com/cloudam/cromwell/domain/JobDescription.java
View file @
d5ebc1a0
...
@@ -14,6 +14,16 @@ public class JobDescription {
...
@@ -14,6 +14,16 @@ public class JobDescription {
*/
*/
private
String
name
;
private
String
name
;
/**
* 作业用户名
*/
private
String
username
;
/**
* 作业用户名
*/
private
String
workflowJobId
;
/**
/**
* 计算区ID
* 计算区ID
*/
*/
...
@@ -67,6 +77,22 @@ public class JobDescription {
...
@@ -67,6 +77,22 @@ public class JobDescription {
this
.
name
=
name
;
this
.
name
=
name
;
}
}
public
String
getUsername
()
{
return
username
;
}
public
void
setUsername
(
String
username
)
{
this
.
username
=
username
;
}
public
String
getWorkflowJobId
()
{
return
workflowJobId
;
}
public
void
setWorkflowJobId
(
String
workflowJobId
)
{
this
.
workflowJobId
=
workflowJobId
;
}
public
String
getZoneId
()
{
public
String
getZoneId
()
{
return
zoneId
;
return
zoneId
;
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment