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

Commit c19dfcc

Browse files
committed
Add test for optional run ID in job meta
Signed-off-by: wslulciuc <[email protected]>
1 parent b1785a7 commit c19dfcc

File tree

1 file changed

+22
-0
lines changed

1 file changed

+22
-0
lines changed

src/test/java/marquez/client/MarquezClientTest.java

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -530,6 +530,28 @@ public void testCreateJob() throws Exception {
530530
assertThat(job).isEqualTo(JOB);
531531
}
532532

533+
@Test
534+
public void testCreateJobWithRunId() throws Exception {
535+
final URL url = buildUrlFor("/namespaces/%s/jobs/%s", NAMESPACE_NAME, JOB_NAME);
536+
537+
final JobMeta meta =
538+
JobMeta.builder()
539+
.type(JOB_TYPE)
540+
.inputs(INPUTS)
541+
.outputs(OUTPUTS)
542+
.location(LOCATION)
543+
.description(JOB_DESCRIPTION)
544+
.context(JOB_CONTEXT)
545+
.runId(newRunId())
546+
.build();
547+
final String metaAsJson = JsonGenerator.newJsonFor(meta);
548+
final String jobAsJson = JsonGenerator.newJsonFor(JOB);
549+
when(http.put(url, metaAsJson)).thenReturn(jobAsJson);
550+
551+
final Job job = client.createJob(NAMESPACE_NAME, JOB_NAME, meta);
552+
assertThat(job).isEqualTo(JOB);
553+
}
554+
533555
@Test
534556
public void testGetJob() throws Exception {
535557
final URL url = buildUrlFor("/namespaces/%s/jobs/%s", NAMESPACE_NAME, JOB_NAME);

0 commit comments

Comments
 (0)