I seem to get this error on some DeltaTables and not others:

df.createOrReplaceTempView("channels_to_delete")

spark.sql("""
    delete from lake.something.earnings
    where TenantId = :tenantId
    and ChannelId = in (
        select ChannelId
        from channels_to_delete
    )
    """,
    args=dict(tenant_id="some_id")
)