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