code: def replicate_rows(
      table: str,
      skip_cols: Set[str],
      multiplier: int = 1,
      suffix: str = "",
  ) -> None:
      cols = get_table_col_names(table) - skip_cols
      cols_str = ", ".join(cols)
  
      with db_cursor() as cur:
          query = f"""
  INSERT INTO {table}( {cols_str} )
  SELECT {cols_str} FROM {table}
  CROSS JOIN generate_series(1, {multiplier}) AS g
  {suffix};
          """
          cur.execute(query)
          print("added rows:", cur.rowcount)
          cur.execute("COMMIT")
  
file_path: determined/tools/scripts/replicate-metrics.py
imports: import concurrent.futures
  import contextlib
  import os
  import time
  from typing import Any, Dict, Generator, List, Set, Tuple, Union
  import psycopg
  from psycopg import sql
label_desc: Use image node_id 3 for calling a global function with example usage: replicate_rows(table, skip_cols, multiplier, suffix) without return types