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:

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?