text: import os
  import time
  
  from airflow.providers.postgres.hooks.postgres import PostgresHook
  from airflow.providers.snowflake.hooks.snowflake import SnowflakeHook
  
  
  def get_table_name(prefix):
      """get unique table name"""
      return prefix + "_" + str(int(time.time()))
  
  
  def drop_table_snowflake(
      table_name: str,
      conn_id: str = "snowflake_conn",
      schema: str = os.environ["SNOWFLAKE_SCHEMA"],
      database: str = os.environ["SNOWFLAKE_DATABASE"],
      warehouse: str = os.environ["SNOWFLAKE_WAREHOUSE"],
  ):
      hook = SnowflakeHook(
          snowflake_conn_id=conn_id,
          schema=schema,
          database=database,
          warehouse=warehouse,
      )
      snowflake_conn = hook.get_conn()
      cursor = snowflake_conn.cursor()
      cursor.execute(f"DROP TABLE IF EXISTS {table_name} CASCADE;")
      snowflake_conn.commit()
      cursor.close()
      snowflake_conn.close()
  
  
  def drop_table_postgres(
      table_name: str, conn_id: str = "postgres_conn", schema: str = "postgres"
  ):
      hook = PostgresHook(postgres_conn_id=conn_id, schema=schema)
      postgres_conn = hook.get_conn()
      cursor = postgres_conn.cursor()
      cursor.execute(f"DROP TABLE IF EXISTS {table_name} CASCADE;")
      postgres_conn.commit()
      cursor.close()
      postgres_conn.close()
  