def METHOD_NAME(
    translator: SQLTranslator, steps: list[PipelineStep], expected: str
):
    translator._source_rows_subset = 42
    pipeline = Pipeline(steps=steps)
    assert translator.get_query_str(steps=pipeline.steps) == expected