Consider this minimal example of a streaming workflow:import os
from pyspark.sql import functions as F, DataFrame
from typing import Literal
# Change these if you want to replicate
CATALOG, SCHEMA = 'partner_demo_catalog', 'ad_sales_demo'
spark.sql...
