Skip to content

Commit 5542e33

Browse files
Address PR comments
1 parent a6058fe commit 5542e33

File tree

3 files changed

+4
-30
lines changed

3 files changed

+4
-30
lines changed

airflow-core/src/airflow/api_fastapi/core_api/services/public/connections.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -61,10 +61,9 @@ def update_orm_from_pydantic(
6161
):
6262
if pydantic_conn.password is None:
6363
orm_conn.set_password(pydantic_conn.password)
64-
return
65-
66-
merged_password = merge(pydantic_conn.password, orm_conn.password, "password")
67-
orm_conn.set_password(merged_password)
64+
else:
65+
merged_password = merge(pydantic_conn.password, orm_conn.password, "password")
66+
orm_conn.set_password(merged_password)
6867
if (not update_mask and "extra" in pydantic_conn.model_fields_set) or (
6968
update_mask and "extra" in update_mask
7069
):

task-sdk/src/airflow/sdk/execution_time/secrets_masker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -350,7 +350,7 @@ def _merge(
350350
merged[key] = new_item[key]
351351
return merged
352352

353-
if isinstance(new_item, (list, tuple)) and isinstance(old_item, (list, tuple)):
353+
if isinstance(new_item, (list, tuple)) and type(old_item) is type(new_item):
354354
merged_list = []
355355
for i in range(len(new_item)):
356356
if i < len(old_item):

task-sdk/tests/task_sdk/definitions/test_secrets_masker.py

Lines changed: 0 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -893,31 +893,6 @@ def test_merge_nested_dictionaries(self):
893893
"normal_tuple",
894894
{"***", "new_value2", "***"},
895895
),
896-
# Mixed collections
897-
(
898-
["original_item1", "original_item2", "original_item3"],
899-
("new_item1", "new_item2"),
900-
None,
901-
("new_item1", "new_item2"),
902-
),
903-
(
904-
("original_item1", "original_item2"),
905-
["new_item1", "new_item2", "new_item3", "new_item4"],
906-
None,
907-
["new_item1", "new_item2", "new_item3", "new_item4"],
908-
),
909-
(
910-
["secret1", "secret2", "secret3"],
911-
("***", "new_secret2", "***"),
912-
"password",
913-
("secret1", "new_secret2", "secret3"),
914-
),
915-
(
916-
("value1", "value2", "value3"),
917-
["***", "new_value2", "***"],
918-
"normal_tuple",
919-
["***", "new_value2", "***"],
920-
),
921896
],
922897
)
923898
def test_merge_collections(self, old_data, new_data, name, expected):

0 commit comments

Comments
 (0)