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?
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
