There were also matches in 3 uncommitted dags on EC2:

~/dags$ grep -nr "\(tomorrow_ds\)\|\(tomorrow_ds_nodash\)\|\(yesterday_ds\)\|\(yesterday_ds_nodash\)\|\(prev_ds\)\|\(prev_ds_nodash\)\|\(prev_execution_date\)\|\(prev_execution_date_success\)\|\(next_execution_date\)\|\(next_ds_nodash\)\|\(next_ds\)\|\(execution_date\)"
queen_park_refresh.py:71:    execution_date = datetime.strptime(date_to_pull, "%Y-%m-%d")
queen_park_refresh.py:72:    if execution_date.weekday() == 0:
queen_park_refresh.py:81:    op_kwargs={'date_to_pull': '{{ yesterday_ds }}'},
queen_park_refresh.py:93:                                          WHERE dt >= '{{ yesterday_ds }}'::date - interval '1 week' and dt < '{{ yesterday_ds }}'::date ''',
queen_park_refresh.py:97:aggregate_queens_park = PostgresOperator(sql='''select data_analysis.generate_queens_park_weekly('{{ macros.ds_add(yesterday_ds, -7) }}') ''',
rapidto_aggregation.py:67:aggregate_daily = PostgresOperator(sql='''SELECT rapidto.generate_daily_hr_agg('{{ yesterday_ds }}')''',
...
refresh_covid_views.py:58:agg_tti = PostgresOperator(sql="SELECT covid.generate_citywide_tti('{{ macros.ds_add(yesterday_ds, -1) }}')",

Airflow 3 - breaking changes #1211

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions