def METHOD_NAME(self, shared_dist_ctx_globaldask, my_ds, benchmark):
    ctx = Context(executor=DelayedJobExecutor())
    udf = EchoUDF()
    resources = DelayedJobExecutor.get_resources_from_udfs(udf)
    def doit():
        result = ctx.run_udf(dataset=my_ds, udf=udf)
        return result['intensity'].delayed_raw_data.sum(axis=0).compute(resources=resources)
    benchmark(doit)