def METHOD_NAME(self, shared_dist_ctx_globaldask, my_ds, benchmark):
    ctx = shared_dist_ctx_globaldask
    udf = EchoUDF()
    def doit():
        result = ctx.run_udf(dataset=my_ds, udf=udf)
        return result['intensity'].raw_data.sum(axis=0)
    benchmark(doit)