Charles Lariviere
01/06/2021, 9:37 PMprefect agent kubernetes install command. I’m running into ImportError when trying to run a flow that uses the SnowflakeQuery Prefect task.
Failed to load and execute Flow's environment: ImportError('Using `prefect.tasks.snowflake` requires Prefect to be installed with the "snowflake" extra.')
I’m wondering where I should specify the dependencies for this flow? I understand that if I was using the Docker storage I would define those in python_dependencies, but I’m not sure where I should define those without using the Docker storage.Charles Lariviere
01/06/2021, 9:37 PM...
from prefect.tasks.snowflake import SnowflakeQuery
config = {
"executor": LocalExecutor(),
"run_config": KubernetesRun(),
"storage": S3(bucket="BUCKET", secrets=["AWS_CREDENTIALS"])
}
...josh
01/06/2021, 9:43 PMKubernetesRun(image="…")Charles Lariviere
01/06/2021, 10:21 PM