def METHOD_NAME(context, run_id):
    """You should almost certainly ensure that this run has complete or terminated in order
    to get reliable results that you can test against.
    """
    check.inst_param(context, "context", BaseWorkspaceRequestContext)
    run = context.instance.get_run_by_id(run_id)
    assert run.is_finished
    subscribe_results = execute_dagster_graphql_subscription(
        context,
        SUBSCRIPTION_QUERY,
        {"runId": run_id},
    )
    assert len(subscribe_results) == 1
    subscribe_result = subscribe_results[0]
    if subscribe_result.errors:
        raise Exception(subscribe_result.errors)
    assert not subscribe_result.errors
    assert subscribe_result.data
    # remove information that changes run-to-run
    assert "pipelineRunLogs" in subscribe_result.data
    assert "messages" in subscribe_result.data["pipelineRunLogs"]
    assert subscribe_result.data["pipelineRunLogs"]["hasMorePastEvents"] is False
    for msg in subscribe_result.data["pipelineRunLogs"]["messages"]:
        msg["runId"] = "<runId dummy value>"
        msg["timestamp"] = "<timestamp dummy value>"
    return subscribe_result.data