Internal change

drive_cse_upload/_cse_crypter.py

@@ -35,7 +35,7 @@ class OpType(enum.Enum):
 
   def __init__(self):
     self._key = None
-    self._aead: aead.Aead = None
+    self._aead: aead.Aead = None  # pyrefly: ignore[bad-assignment]
     self._current_chunk_count = 0
     aead.register()
 
@@ -123,7 +123,7 @@ def _update(self, data, optype, is_last_chunk):
       case self.OpType.DECRYPT:
         chunk = self._aead.decrypt(data, associated_data)
     self._current_chunk_count += 1
-    return chunk
+    return chunk  # pyrefly: ignore[unbound-name]
 
   def _get_key_from_handle(self, keyset_handle):
     keyset = keyset_handle._keyset  # pylint: disable=protected-access

drive_cse_upload/_cse_idp_client.py

@@ -45,7 +45,7 @@ def __init__(self, client_secret_file, saved_creds_file):
     """
     self._client_secret_file = client_secret_file
     self._saved_creds_file = saved_creds_file
-    self._creds: credentials.Credentials = None
+    self._creds: credentials.Credentials = None  # pyrefly: ignore[bad-assignment]
     self._lock = threading.Lock()
 
   def get_authn_token(self):

drive_cse_upload/_cse_kacls_client.py

@@ -56,7 +56,7 @@ def privileged_wrap(
         'reason': 'import',
     }
     r = requests.post(wrap_url, json=request)
-    if r.status_code != requests.codes.ok:
+    if r.status_code != requests.codes.ok:  # pyrefly: ignore[missing-attribute]
       raise RuntimeError('Wrap failed: ' + r.text)
     response = r.json()
     return response['wrapped_key']
@@ -84,7 +84,7 @@ def privileged_unwrap(self, wrapped_key, resource_name, authn, kacls_url):
         'reason': 'import',
     }
     r = requests.post(unwrap_url, json=request)
-    if r.status_code != requests.codes.ok:
+    if r.status_code != requests.codes.ok:  # pyrefly: ignore[missing-attribute]
       raise RuntimeError('Unwrap failed: ' + r.text)
     response = r.json()
     return response['key']