Skip to content

Commit dbe37c2

Browse files
author
François Delbrayelle
committed
chore: update kestraVersion to 1.2.3
1 parent c1fd1de commit dbe37c2

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
version=1.0.2-SNAPSHOT
2-
kestraVersion=1.0.0
2+
kestraVersion=1.2.3
33
beamVersion=2.69.0

src/main/java/io/kestra/plugin/beam/package-info.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
@PluginSubGroup(
2-
categories = {PluginSubGroup.PluginCategory.TRANSFORMATION, PluginSubGroup.PluginCategory.BATCH, PluginSubGroup.PluginCategory.INGESTION},
2+
categories = {PluginSubGroup.PluginCategory.DATA},
33
description = "Run Apache Beam pipelines on Direct, Flink, Spark, or Dataflow runners.",
44
title = "Apache Beam"
55
)

src/test/java/io/kestra/plugin/beam/RunPipelineTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ void shouldLoadDefinitionFromNamespaceStorage() throws Exception {
6969
URI stored = runContext.storage().namespace().putFile(
7070
java.nio.file.Path.of("pipeline.yaml"),
7171
new ByteArrayInputStream(yaml.getBytes(StandardCharsets.UTF_8))
72-
).uri();
72+
).getLast().uri();
7373

7474
RunPipeline withFile = RunPipeline.builder()
7575
.id(configured.getId())

0 commit comments

Comments
 (0)