Update read_dlt_delta() to read "source_database" instead of "database"

onboard_dataflowspec.py sets key "source_database" when creating bronze dataflow spec dataframe inside source details. However read_dlt_delta tries to read "database" instead.

Author: rtdtwo

src/pipeline_readers.py

@@ -62,14 +62,14 @@ def read_dlt_delta(spark, bronze_dataflow_spec) -> DataFrame:
         if reader_config_options and len(reader_config_options) > 0:
             return (
                 spark.readStream.options(**reader_config_options).table(
-                    f"""{bronze_dataflow_spec.sourceDetails["database"]}
+                    f"""{bronze_dataflow_spec.sourceDetails["source_database"]}
                         .{bronze_dataflow_spec.sourceDetails["table"]}"""
                 )
             )
         else:
             return (
                 spark.readStream.table(
-                    f"""{bronze_dataflow_spec.sourceDetails["database"]}
+                    f"""{bronze_dataflow_spec.sourceDetails["source_database"]}
                         .{bronze_dataflow_spec.sourceDetails["table"]}"""
                 )
             )