Is there a way to customize the

name

of a

SnowflakeQuery

task similar to @task to give it a human meaning name? I didn't see it in https://docs.prefect.io/api/latest/tasks/snowflake.html

I think you can specify

name='human_meaning_name'

to the

**kwargs

**kwargs (dict, optional): additional keyword arguments to pass to the Task constructor

Ah, right. Thanks@!

no problem!

Has anyone used

map

with

SnowflakeQuery

to load multiple parquet datasets? Or are these usually discrete tasks?

I think you can map it

snowflake_query = SnowflakeQuery(
    account=Secret("SNOWFLAKE_ACCOUNT").get(),
    user=Secret("SNOWFLAKE_USER").get(),
    password=Secret("SNOWFLAKE_PASSWORD").get(),
    ...
)
with Flow("weather_notifications", schedule=schedule) as flow:
    snowflake_query.map(...)

You should be able to map it yes. But you need to handle concurrent connections to Snowflake, otherwise you may get errors

What gets mapped, in that case? Am I setting up a callable like:

@task
def snowflake_query(name, s3_path):
    return SnowflakeQuery(...)

No in Andrew’s example, it would be:

with Flow():
    snowflake_query.map(query=list_of_queries)

For example

Ah, the kwargs. I see. OK interesting