Hi,
First foray into DLT and following code exerts from the sample-DLT-notebook.
I'm creating a notebook with the SQL below:
CREATE STREAMING LIVE TABLE sales_orders_raw
COMMENT "The raw sales orders, ingested from /databricks-datasets."
TBLPROPERTIES ("myCompanyPipeline.quality" = "bronze")
AS
SELECT * FROM cloud_files("/databricks-datasets/retail-org/sales_orders/", "json", map("cloudFiles.inferColumnTypes", "true"))
I then reference this in my DLT pipeline but it fails on initialising with a syntax error (pic attached). Can anyone assist? Appreciate it says python and I'm using SQL but thought the pipeline transposed as magic commands aren't permitted in notebook being called in DLT pipe.