Hi all,I have very simple pipeline: -- Databricks notebook source
CREATE OR REFRESH STREAMING TABLE `catalog-prod`.default.dlt_table AS
SELECT * FROM STREAM read_files('/Volumes/catalog-prod/storage/*', format=> 'json')
-- COMMAND ----------
CREATE...