async def METHOD_NAME(task: BaseTask, pg: AsyncEngine):
    task.step = task.steps[0]
    tracker_1 = task.create_progress_handler()
    await tracker_1.set_progress(50)
    assert (await get_row_by_id(pg, SQLTask, 1)).progress == 25
    await tracker_1.set_progress(100)
    assert (await get_row_by_id(pg, SQLTask, 1)).progress == 50
    task.step = task.steps[1]
    tracker_2 = task.create_progress_handler()
    await tracker_2.set_progress(100)
    assert (await get_row_by_id(pg, SQLTask, 1)).progress == 100