def METHOD_NAME(
    session_name, scan_new_callback, scan_data_callback, scan_end_callback
):
    """Watch the bliss session for new data"""
    session_node = get_or_create_node(session_name, node_type="session")
    if session_node is not None:
        data_iterator = DataNode("session", session_name)
        watch_data_task = None
        last = True
        for scan_node in data_iterator.walk_from_last(filter="scan"):
            if last:
                # skip the last one, we are interested in new ones only
                last = False
                continue
            if watch_data_task:
                watch_data_task.kill()
            watch_data_task = gevent.spawn(
                watch_data,
                scan_node,
                scan_new_callback,
                scan_data_callback,
                scan_end_callback,
            )