Skip to contents

Which execution route did the last collect() take?

garry_last_route.Rd

A diagnostics helper. The distributed collect() picks its execution route automatically, and this reports the route the last call took, so pipelines can log it or assert a plan has not changed route. The values are:

Usage

garry_last_route()

Value

"composite_direct", "gd_reduce", "scheduler" or "single"; NULL before any collect() in the session.

Details

  • "composite_direct": the specialised masked-composite executor;

  • "gd_reduce": the general reduce-decomposition executor;

  • "scheduler": the general distributed scheduler;

  • "single": the in-process single-threaded executor (distributed = FALSE).