def METHOD_NAME(
    select_val: int,
    task: AbstractOperator,
):
    pg = PostgresHook(
        default_statement_timeout=PostgresHook.get_execution_timeout(task),
        conn_id=POSTGRES_CONN_ID,
    )
    return pg.run(f"select {select_val};")