https://prefect.io logo
#prefect-community
Title
# prefect-community
t

Ton Steijvers

02/10/2023, 2:14 PM
I have a flow that has
retries=3
. One of my tasks returns a
SnowflakeConnector
that gets passed to a few other tasks that perform queries on the db. If one of the tasks fails, the flow is retried and throws the following exception:
Copy code
pydantic.error_wrappers.ValidationError: 1 validation error for ParsingModel[SnowflakeConnector]
__root__ -> schema
  field required (type=value_error.missing)
This is probably because of the
SecretStr
field in the
SnowflakeConnector
that holds the password. In
~/.prefect/storage
I can see the persisted results of the tasks and secret strings are obviously obfuscated. How is the retry mechanism supposed to work if my tasks work with SecretStr of SnowflakeConnections?