fix azure service bus isinstance check

celery · Jul 9, 2024 · 1867154 · 1867154
1 parent 4fb7246
commit 1867154
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/kombu/transport/azureservicebus.py b/kombu/transport/azureservicebus.py
@@ -141,9 +141,9 @@ def _try_parse_connection_string(self) -> None:
         self._namespace, self._credential = Transport.parse_uri(
             self.conninfo.hostname)
 
-        if (isinstance(self._credential, DefaultAzureCredential) or
-                isinstance(self._credential, ManagedIdentityCredential)):
-            return None
+        if (DefaultAzureCredential is not None and isinstance(self._credential, DefaultAzureCredential)) or \
+           (ManagedIdentityCredential is not None and isinstance(self._credential, ManagedIdentityCredential)):
+               return None
 
         if ":" in self._credential:
             self._policy, self._sas_key = self._credential.split(':', 1)