From 21828506dabce4e364fb10ff6e342289f2d55d42 Mon Sep 17 00:00:00 2001 From: Westm7 Date: Fri, 3 Jan 2025 12:40:26 +1100 Subject: [PATCH] [embedded-elt][sling] Correctly get an object_key when a stream has an empty config Fixes #25515 and #25925 --- .../dagster_embedded_elt/sling/resources.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/sling/resources.py b/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/sling/resources.py index c0d57e6e643ea..d52cf19fffb03 100644 --- a/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/sling/resources.py +++ b/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/sling/resources.py @@ -403,7 +403,7 @@ def _replicate( for stream in stream_definitions: asset_key = dagster_sling_translator.get_asset_key(stream) - object_key = stream.get("config", {}).get("object") + object_key = (stream.get("config") or {}).get("object") destination_stream_name = object_key or stream["name"] table_name = None if destination_name and destination_stream_name: