def METHOD_NAME(default_raw):
    with lt.Context.make_with("pipelined") as ctx:
        reporter = TrackingTQDM()
        udf = GoSlowSumUDF()
        ctx.run_udf(default_raw, udf, progress=reporter)
        assert reporter._bar.n == reporter._bar.total
        num_part = default_raw.get_num_partitions()
        # Run start / stop + (part start / stop * num_part)
        min_num_messages = 2 + num_part * 2
        # default_raw doesn't have enough tiles to send intermediate
        # tile messages (depending on the system resources), but we can at least
        # check the comms are working by verifying we had min_num_messages
        assert len(reporter._history) >= min_num_messages