Ignore "404 Not Found" when patching after deletion during handling

kopf/clients/patching.py

@@ -1,5 +1,8 @@
 import asyncio
 
+import pykube
+import requests
+
 from kopf import config
 from kopf.clients import auth
 from kopf.clients import classes
@@ -31,5 +34,14 @@ async def patch_obj(*, resource, patch, namespace=None, name=None, body=None):
     cls = classes._make_cls(resource=resource)
     obj = cls(api, body)
 
-    loop = asyncio.get_running_loop()
-    await loop.run_in_executor(config.WorkersConfig.get_syn_executor(), obj.patch, patch)
+    # The handler could delete its own object, so we have nothing to patch. It is okay, ignore.
+    try:
+        loop = asyncio.get_running_loop()
+        await loop.run_in_executor(config.WorkersConfig.get_syn_executor(), obj.patch, patch)
+    except pykube.ObjectDoesNotExist:
+        pass
+    except requests.exceptions.HTTPError as e:
+        if e.response.status_code in [404]:
+            pass
+        else:
+            raise

tests/k8s/test_patching.py

@@ -1,6 +1,7 @@
 import json
 
 import pytest
+import requests
 
 from kopf.clients.patching import patch_obj
 
@@ -98,3 +99,30 @@ async def test_raises_when_body_conflicts_with_ids(req_mock, resource):
         await patch_obj(resource=resource, body=body, namespace='ns1', name='name1', patch=patch)
 
     assert not req_mock.patch.called
+
+
+@pytest.mark.parametrize('status', [404])
+async def test_ignores_absent_objects(req_mock, resource, status):
+    response = requests.Response()
+    response.status_code = status
+    error = requests.exceptions.HTTPError("boo!", response=response)
+    req_mock.patch.side_effect = error
+
+    patch = {'x': 'y'}
+    body = {'metadata': {'namespace': 'ns1', 'name': 'name1'}}
+    await patch_obj(resource=resource, body=body, patch=patch)
+
+
+@pytest.mark.parametrize('namespace', [None, 'ns1'], ids=['without-namespace', 'with-namespace'])
+@pytest.mark.parametrize('status', [400, 401, 403, 500, 666])
+async def test_raises_api_errors(req_mock, resource, namespace, status):
+    response = requests.Response()
+    response.status_code = status
+    error = requests.exceptions.HTTPError("boo!", response=response)
+    req_mock.patch.side_effect = error
+
+    patch = {'x': 'y'}
+    body = {'metadata': {'namespace': 'ns1', 'name': 'name1'}}
+    with pytest.raises(requests.exceptions.HTTPError) as e:
+        await patch_obj(resource=resource, body=body, patch=patch)
+    assert e.value.response.status_code == status

tests/k8s/test_read_obj.py

@@ -1,4 +1,3 @@
-import pykube
 import pytest
 import requests