client := shared.NewPicoPipeClient(ctx, logger)
drain := client.sub("container-drain -k")
send := client.pub("metric-drain -b=false")