def METHOD_NAME(emr_cluster_config):
    context = create_test_pipeline_execution_context()
    emr = EmrJobRunner(region=REGION)
    cluster_id = emr.run_job_flow(context.log, emr_cluster_config)
    emr.add_tags(context.log, {"foobar": "v1", "baz": "123"}, cluster_id)
    tags = emr.describe_cluster(cluster_id)["Cluster"]["Tags"]
    assert {"Key": "baz", "Value": "123"} in tags
    assert {"Key": "foobar", "Value": "v1"} in tags