Skip to content
This repository was archived by the owner on Nov 22, 2020. It is now read-only.

Commit 61a1fb4

Browse files
committed
Add flag to start run on create
Signed-off-by: wslulciuc <[email protected]>
1 parent 53ff51a commit 61a1fb4

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

src/main/java/marquez/client/MarquezClient.java

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -246,15 +246,23 @@ public List<Job> listJobs(@NonNull String namespaceName, int limit, int offset)
246246
return Jobs.fromJson(bodyAsJson).getValue();
247247
}
248248

249+
public Run createRun(String jobName, RunMeta meta, boolean markRunAsRunning) {
250+
return createRun(namespaceName, jobName, meta, markRunAsRunning);
251+
}
252+
249253
public Run createRun(String jobName, RunMeta meta) {
250-
return createRun(namespaceName, jobName, meta);
254+
return createRun(namespaceName, jobName, meta, false);
251255
}
252256

253257
public Run createRun(
254-
@NonNull String namespaceName, @NonNull String jobName, @NonNull RunMeta meta) {
258+
@NonNull String namespaceName,
259+
@NonNull String jobName,
260+
@NonNull RunMeta meta,
261+
boolean markRunAsRunning) {
255262
final String bodyAsJson =
256263
http.post(http.url("/namespaces/%s/jobs/%s/runs", namespaceName, jobName), meta.toJson());
257-
return Run.fromJson(bodyAsJson);
264+
final Run run = Run.fromJson(bodyAsJson);
265+
return (markRunAsRunning) ? markRunAsRunning(run.getId()) : run;
258266
}
259267

260268
public Run getRun(@NonNull String runId) {

0 commit comments

Comments
 (0)