only consider aiohttp.ClientResponse instances when collecting respon…

…ses related to a session

Signed-off-by: Steven Armstrong <[email protected]>

kopf/_cogs/clients/auth.py

@@ -38,17 +38,19 @@ async def wrapper(*args: Any, **kwargs: Any) -> Any:
         if 'context' in kwargs:
             context = kwargs['context']
             response = await fn(*args, **kwargs)
-            # Keep track of responses which are using this context.
-            context.add_response(response)
+            if isinstance(response, aiohttp.ClientResponse):
+                # Keep track of responses which are using this context.
+                context.add_response(response)
             return response
 
         # Otherwise, attempt the execution with the vault credentials and re-authenticate on 401s.
         vault: credentials.Vault = vault_var.get()
         async for key, info, context in vault.extended(APIContext, 'contexts'):
             try:
                 response = await fn(*args, **kwargs, context=context)
-                # Keep track of responses which are using this context.
-                context.add_response(response)
+                if isinstance(response, aiohttp.ClientResponse):
+                    # Keep track of responses which are using this context.
+                    context.add_response(response)
                 return response
             except errors.APIUnauthorizedError as e:
                 await vault.invalidate(key, exc=e)