Airflow RedshiftToS3Operator: using parameters
I’m tryng to pass parameters into my query sql using parameters parameter into a RedshiftToS3Operator. I don’t understand how to use my parameters into my query. Here is my query into a mycode.sql file: Select * From my_table where date_start = {{ data_interval_end.subtract(days=day_as_parameters)}} Using the Operator like this : unload_data_to_s3 = RedshiftToS3Operator( task_id="unload_data_to_s3", s3_bucket=S3_BUCKET, s3_key=S3_KEY,… Read More Airflow RedshiftToS3Operator: using parameters