Skip to content

Commit

Permalink
Fix RTIF test against the apply-expand (#22121)
Browse files Browse the repository at this point in the history
  • Loading branch information
uranusjr committed Mar 9, 2022
1 parent bedc1c8 commit a4d514b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion tests/models/test_renderedtifields.py
Original file line number Diff line number Diff line change
Expand Up @@ -211,7 +211,7 @@ def test_delete_old_records_mapped(
for a given task_id and dag_id with mapped tasks.
"""
with dag_maker("test_delete_old_records", session=session) as dag:
mapped = BashOperator.partial(task_id="mapped").apply(bash_command=['a', 'b'])
mapped = BashOperator.partial(task_id="mapped").expand(bash_command=['a', 'b'])
for num in range(num_runs):
dr = dag_maker.create_dagrun(
run_id=f'run_{num}', execution_date=dag.start_date + timedelta(days=num)
Expand Down

0 comments on commit a4d514b

Please sign in to comment.