def METHOD_NAME(self, start_south_north, read_data_from_pi, fledge_url, pi_host, pi_admin, pi_passwd, pi_db,
                    wait_time, retries, skip_verify_north_interface, asset_name=ASSET_NAME):
    """ Test that data is inserted in Fledge and sent to PI
        start_south_north: Fixture that starts Fledge with south and north instance
        read_data_from_pi: Fixture to read data from PI
        skip_verify_north_interface: Flag for assertion of data from Pi web API
        Assertions:
            on endpoint GET /fledge/asset
            on endpoint GET /fledge/asset/<asset_name>
            data received from PI is same as data sent"""
    conn = http.client.HTTPConnection(fledge_url)
    time.sleep(wait_time)
    subprocess.run(["cd $FLEDGE_ROOT/extras/python; python3 -m fogbench -t ../../data/{}; cd -".format(TEMPLATE_NAME)],
                   shell=True, check=True)
    # Time to wait until north schedule runs
    time.sleep(wait_time * math.ceil(15/wait_time) + 15)
    ping_response = get_ping_status(fledge_url)
    assert 1 == ping_response["dataRead"]
    if not skip_verify_north_interface:
        assert 1 == ping_response["dataSent"]
    actual_stats_map = get_statistics_map(fledge_url)
    assert 1 == actual_stats_map[asset_name.upper()]
    assert 1 == actual_stats_map['READINGS']
    if not skip_verify_north_interface:
        assert 1 == actual_stats_map['Readings Sent']
        assert 1 == actual_stats_map['NorthReadingsToPI']
    conn.request("GET", '/fledge/asset')
    r = conn.getresponse()
    assert 200 == r.status
    r = r.read().decode()
    retval = json.loads(r)
    assert len(retval) == 1
    assert asset_name == retval[0]["assetCode"]
    assert 1 == retval[0]["count"]
    conn.request("GET", '/fledge/asset/{}'.format(asset_name))
    r = conn.getresponse()
    assert 200 == r.status
    r = r.read().decode()
    retval = json.loads(r)
    assert {'sensor': SENSOR_VALUE} == retval[0]["reading"]
    if not skip_verify_north_interface:
        _verify_egress(read_data_from_pi, pi_host, pi_admin, pi_passwd, pi_db, wait_time, retries, asset_name)
    tracking_details = utils.get_asset_tracking_details(fledge_url, "Ingest")
    assert len(tracking_details["track"]), "Failed to track Ingest event"
    tracked_item = tracking_details["track"][0]
    assert "coap" == tracked_item["service"]
    assert ASSET_NAME == tracked_item["asset"]
    assert "coap" == tracked_item["plugin"]
    if not skip_verify_north_interface:
        egress_tracking_details = utils.get_asset_tracking_details(fledge_url,"Egress")
        assert len(egress_tracking_details["track"]), "Failed to track Egress event"
        tracked_item = egress_tracking_details["track"][0]
        assert "NorthReadingsToPI" == tracked_item["service"]
        assert ASSET_NAME == tracked_item["asset"]
        assert "OMF" == tracked_item["plugin"]