rodrigocollavo commented on issue #19251:
URL: https://github.com/apache/airflow/issues/19251#issuecomment-1344491172
I had to extend the functionality to make it works with airflow connections
as well, adding the following function to the code mentioned above:
```
def get_conn_value(self, key: str) -> Optional[str]:
if self.connections_prefix is None:
return None
if self.secret_lookup_prefix is not None:
if not key.startswith(self.secret_lookup_prefix):
return None
secret = self._get_secret(self.connections_prefix, key)
return secret
```
@maxexcloo probably you would like to add it to your package. I've tried
yours first, but then I had to create a custom one to support connections in
the secret manager.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
