Skip to content

Commit b58e27d

Browse files
committed
Java SDK: Write each Dag tag once, as Python does
1 parent d4526e3 commit b58e27d

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

  • java-sdk/sdk/src
    • main/kotlin/org/apache/airflow/sdk/execution
    • test/kotlin/org/apache/airflow/sdk/execution

‎java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Serde.kt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ private fun applyDagConfig(
167167
(config["tags"] as? List<*>)?.let { tags ->
168168
// Python stores tags in a set and serializes them sorted (for a stable
169169
// dag_hash); mirror that regardless of registration order.
170-
data["tags"] = tags.map { it.toString() }.sorted()
170+
data["tags"] = tags.map { it.toString() }.distinct().sorted()
171171
}
172172
listOf(
173173
"max_active_tasks",

‎java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/execution/SerdeTest.kt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ internal class SerdeTest {
119119
val dag =
120120
DagDef("d")
121121
.config("description", "demo")
122-
.config("tags", listOf("b", "a"))
122+
.config("tags", listOf("b", "a", "b"))
123123
.config("catchup", true)
124124
.config("fail_fast", true)
125125
.config("max_active_runs", 3)

0 commit comments

Comments
 (0)