Ton Steijvers
02/10/2023, 2:14 PMretries=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:
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?