send task: log delay from when Object was created

for #1308, 85b9643
snarfed · Sep 18, 2024 · 5884be8 · 5884be8
1 parent 85b9643
commit 5884be8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/protocol.py b/protocol.py
@@ -1709,7 +1709,10 @@ def send_task():
                 if form.get('orig_obj') else None)
 
     # send
-    logger.info(f'Sending {obj.source_protocol} {obj.type} {obj.key.id()} to {protocol} {url}')
+    delay = ''
+    if request.headers.get('X-AppEngine-TaskRetryCount') == '0' and obj.created:
+        delay = f'({(util.now().replace(tzinfo=None) - obj.created).total_seconds()} s behind)'
+    logger.info(f'Sending {obj.source_protocol} {obj.type} {obj.key.id()} to {protocol} {url} {delay}')
     logger.debug(f'  AS1: {json_dumps(obj.as1, indent=2)}')
     sent = None
     try:

diff --git a/tests/test_protocol.py b/tests/test_protocol.py
@@ -3199,7 +3199,7 @@ def test_send_task_handler(self):
             'orig_obj': note.key.urlsafe(),
             'url': 'fake:shared:target',
             'user': self.user.key.urlsafe(),
-        })
+        }, headers={'X-AppEngine-TaskRetryCount': '0'})
         self.assertEqual(200, resp.status_code)
 
     def test_send_task_missing_url(self):