def METHOD_NAME(
    app_config: AppConfig,
    get_job_runner: GetJobRunner,
    upstream_responses: List[UpstreamResponse],
    expected: Any,
) -> None:
    dataset = DATASET
    upsert_response(**UPSTREAM_RESPONSE_CONFIG_NAMES)
    for upstream_response in upstream_responses:
        upsert_response(**upstream_response)
    job_runner = get_job_runner(dataset, app_config)
    compute_result = job_runner.compute()
    assert compute_result.content == expected[0]
    assert compute_result.progress == expected[1]