class_docstr: Program definition for distributional (MoG) MPO.
class_docstr_tok: ["Program","definition","for","distributional","(","MoG",")","MPO","."]
code: def coordinator(
      self, counter: counting.Counter, max_actor_steps: int
  ):
      return lp_utils.StepsLimiter(counter, max_actor_steps)
  
imports: from typing import Callable, Dict, Optional
  import acme
  from acme import datasets
  from acme import specs
  from acme.adders import reverb
  from acme.agents.tf import actors
  from acme.agents.tf.mog_mpo import learning
  from acme.tf import networks
  from acme.tf import savers
  from acme.tf import variable_utils
  from acme.utils import counting
  from acme.utils import loggers
  from acme.utils import lp_utils
  import dm_env
  import launchpad
  import reverb
  import sonnet
label_desc: Use image node_id 4 for calling the DistributedMoGMPO obj's underlying member method code with example usage: obj.coordinator(counter, max_actor_steps) and returns: lp_utils