code: def __init__(
      self, ctx: Context, aggregator_name: Optional[str] = None
  ):
      if aggregator_name is not None:
          agg_name = "_" + aggregator_name
      else:
          agg_name = ""
      self.suffix = {
          "local_loss": AutoSuffix("local_loss" + agg_name),
          "agg_loss": AutoSuffix("agg_loss" + agg_name),
          "local_model": AutoSuffix("local_model" + agg_name),
          "agg_model": AutoSuffix("agg_model" + agg_name),
          "converge_status": AutoSuffix("converge_status" + agg_name),
          "local_weight": AutoSuffix("local_weight" + agg_name),
          "computed_weight": AutoSuffix("agg_weight" + agg_name),
      }
  
imports: import logging
  from typing import Optional
  import numpy
  import torch
  from fate.arch import Context
  from fate.arch.protocol.secure_aggregation._secure_aggregation import SecureAggregatorClient
  from fate.arch.protocol.secure_aggregation._secure_aggregation import SecureAggregatorServer
label_desc: Use image node_id 1 to create a new Aggregator object  with example: obj = Aggregator(ctx, aggregator_name)