Ton Steijvers02/10/2023, 2:14 PM
. One of my tasks returns a
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:
This is probably because of the
pydantic.error_wrappers.ValidationError: 1 validation error for ParsingModel[SnowflakeConnector] __root__ -> schema field required (type=value_error.missing)
field in the
that holds the password. In
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?