import snowflake.snowpark as snowpark from utils.common import get_sql_result def get_users(session: snowpark.Session, p_date: str): schema = """ select user_id, uid as user_uid from rds_discord_info d inner join rds_auth_user a on d.user_id = a.id where 1=1 and date(a.date_joined) <= '{p_date}' """.format(p_date=p_date) return get_sql_result(session, schema)