在您的代码中,需要确保在使用 'conn' 变量之前定义了该变量。这可以通过使用以下方法解决:
from airflow import DAG
from airflow.models import Variable, Connection
conn = Connection.get_connection_from_secrets('your_connection_id')
if 'conn' not in locals():
conn = Connection.get_connection_from_secrets('your_connection_id')
通过这些步骤,您的代码应该可以正常工作并消除 "templating conn not defined" 的错误。