When the bronze_dataflow_spec dataframe is created in onboard_dataflowspec.py, the database is included with key source_database in the sourceDetails field. However, in pipeline_readers.py > read_dlt_delta(), it is accessed with key database instead.
Fix:
Change the key to source_database in pipeline_readers.py > read_dlt_delta().
Issue:
When the bronze_dataflow_spec dataframe is created in
onboard_dataflowspec.py
, the database is included with keysource_database
in thesourceDetails
field. However, inpipeline_readers.py
>read_dlt_delta()
, it is accessed with keydatabase
instead.Fix:
Change the key to
source_database
inpipeline_readers.py
>read_dlt_delta()
.