Fix handling of failed items in Base.put

deta/_async/client.py

@@ -93,14 +93,12 @@ async def put(
             data["key"] = key
 
         insert_ttl(data, self.__ttl_attribute, expire_in=expire_in, expire_at=expire_at)
-        async with self._session.put(
-            f"{self._base_url}/items", json={"items": [data]}
-        ) as resp:
+        async with self._session.put(f"{self._base_url}/items", json={"items": [data]}) as resp:
             if resp.status == 207:
                 resp_json = await resp.json()
-                return resp_json["processed"]["items"][0]
-            else:
-                return None
+                if "processed" in resp_json:
+                    return resp_json["processed"]["items"][0]
+            return None
 
     async def put_many(
         self,

deta/base.py

@@ -158,7 +158,11 @@ def put(
         code, res = self._request(
             "/items", "PUT", {"items": [data]}, content_type=JSON_MIME
         )
-        return res["processed"]["items"][0] if res and code == 207 else None
+
+        if code == 207 and "processed" in res:
+            return res["processed"]["items"][0]
+        else:
+            return None
 
     def put_many(
         self,

deta/service.py

@@ -84,7 +84,8 @@ def _request(
             ## return None if not found
             if status == 404:
                 return status, None
-            raise urllib.error.HTTPError(url, status, res.reason, res.headers, res.fp)
+            fp = res.fp if res.fp is not None else ''  # FIXME: workaround to fix traceback printing for HTTPError
+            raise urllib.error.HTTPError(url, status, res.reason, res.headers, fp)
 
         ## if stream return the response and client without reading and closing the client
         if stream:

deta/utils.py

@@ -13,4 +13,4 @@ def _get_project_key_id(project_key: str = None, project_id: str = None):
     if project_id == project_key:
         raise AssertionError("Bad project key provided")
 
-    return project_key, project_id
+    return project_key, project_id

tests/test_async.py

@@ -258,7 +258,7 @@ def get_expire_in(expire_in):
 async def test_ttl(db, items):
     item1 = items[0]
     expire_in = 300
-    expire_at = datetime.datetime(2022, 3, 1, 12, 30, 30)
+    expire_at = datetime.datetime.now() + datetime.timedelta(seconds=300)
     delta = 2  # allow time delta of 2 seconds
     test_cases = [
         {

tests/test_sync.py

@@ -382,7 +382,7 @@ def get_expire_in(self, expire_in):
 
     def test_ttl(self):
         expire_in = 300
-        expire_at = datetime.datetime(2022, 3, 1, 12, 30, 30)
+        expire_at = datetime.datetime.now() + datetime.timedelta(seconds=300)
         delta = 2  # allow time delta of 2 seconds
         test_cases = [
             {