(self)
| 661 | with_options = copy |
| 662 | |
| 663 | async def _get_azure_ad_token(self) -> str | None: |
| 664 | if self._azure_ad_token is not None: |
| 665 | return self._azure_ad_token |
| 666 | |
| 667 | provider = self._azure_ad_token_provider |
| 668 | if provider is not None: |
| 669 | token = provider() |
| 670 | if inspect.isawaitable(token): |
| 671 | token = await token |
| 672 | if not token or not isinstance(cast(Any, token), str): |
| 673 | raise ValueError( |
| 674 | f"Expected `azure_ad_token_provider` argument to return a string but it returned {token}", |
| 675 | ) |
| 676 | return str(token) |
| 677 | |
| 678 | return None |
| 679 | |
| 680 | @override |
| 681 | def _auth_headers(self, security: SecurityOptions) -> dict[str, str]: # noqa: ARG002 |
no test coverage detected