code: def init_copy(self, connection):
          
          if not self.does_schema_exist(connection):
              logger.info("Creating schema for %s", self.table)
              self.create_schema(connection)
  
          if not self.does_table_exist(connection):
              logger.info("Creating table %s", self.table)
              self.create_table(connection)
  
          if self.enable_metadata_columns:
              self._add_metadata_columns(connection)
  
          if self.do_truncate_table:
              logger.info("Truncating table %s", self.table)
              self.truncate_table(connection)
  
          if self.do_prune():
              logger.info("Removing %s older than %s from %s", self.prune_column, self.prune_date, self.prune_table)
              self.prune(connection)
docs: Perform pre-copy sql - such as creating table, truncating, or removing data older than x.