Flujo de aire: pase {{ds}} como parámetro a PostgresOperator
Me gustaría usar la fecha de ejecución como parámetro para mi archivo sql:
Lo intenté
dt = '{{ ds }}'
s3_to_redshift = PostgresOperator(
task_id='s3_to_redshift',
postgres_conn_id='redshift',
sql='s3_to_redshift.sql',
params={'file': dt},
dag=dag
)
Pero no funciona.