o código do airflow nao funciona, entao pedi pra o chatgpt corrigir e ele me ofereceu essa alternativa aqui:
from airflow import DAG
from airflow.providers.databricks.operators.databricks import DatabricksRunNowOperator
from datetime import datetime
with DAG(
'Executando-notebook-etl',
start_date=datetime(2025, 7, 5),
schedule_interval="0 9 * * *",
catchup=True
) as dag_executando_notebook_extracao:
extraindo_dados = DatabricksRunNowOperator(
task_id='Extraindo-conversoes',
databricks_conn_id='databricks_default',
job_id=job aqui,
notebook_params={"data_execucao": '{{data_interval_end.strftime("%Y-%m-%d")}}'}
)
no entanto ele só retorna o dia atual no airflow, não os dias meses atras. Não sei muito de airflow e nao sei o que fazer