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: