DBT on python: dynamic generated sql query use case

[sunnylilili]

We have a bunch of data pipeline running python function like
def gen_sql():

In the function:

1. we first connect to snowflake to get a table schema.
2. do some string manipulation on the schema and generate a SQL query
3. return the query.
4. Then query will run in snowflake and create some downstream table.

Is it possible to do it in DBT?

1. Need to support not a "hard coded" SQL file but a python dynamic generated query.

2. Even better would support a library running snowflake conn to get table schema. (This is not as big a blocker as 1))