def METHOD_NAME(aggregator, dd_run_check, bad_instance):
    """
    Test the right service check is sent upon _get_connection failures
    """
    bad_instance.update({'tags': ['optional:tag1']})
    oracle_check = Oracle(CHECK_NAME, {}, [bad_instance])
    expected_tags = ['server:localhost:1521', 'optional:tag1']
    dd_run_check(oracle_check)
    aggregator.assert_service_check("oracle.can_connect", Oracle.CRITICAL, count=1, tags=expected_tags)
    aggregator.assert_service_check("oracle.can_query", Oracle.CRITICAL, count=1, tags=expected_tags)
    assert oracle_check._cached_connection is None