send task_received signal before receive log

celery/worker/strategy.py

@@ -148,17 +148,7 @@ def task_message_handler(message, body, ack, reject, callbacks,
             eventer=eventer, task=task, connection_errors=connection_errors,
             body=body, headers=headers, decoded=decoded, utc=utc,
         )
-        if _does_info:
-            # Similar to `app.trace.info()`, we pass the formatting args as the
-            # `extra` kwarg for custom log handlers
-            context = {
-                'id': req.id,
-                'name': req.name,
-                'args': req.argsrepr,
-                'kwargs': req.kwargsrepr,
-                'eta': req.eta,
-            }
-            info(_app_trace.LOG_RECEIVED, context, extra={'data': context})
+
         if (req.expires or req.id in revoked_tasks) and req.revoked():
             return
 
@@ -175,6 +165,18 @@ def task_message_handler(message, body, ack, reject, callbacks,
                 expires=req.expires and req.expires.isoformat(),
             )
 
+        if _does_info:
+            # Similar to `app.trace.info()`, we pass the formatting args as the
+            # `extra` kwarg for custom log handlers
+            context = {
+                'id': req.id,
+                'name': req.name,
+                'args': req.argsrepr,
+                'kwargs': req.kwargsrepr,
+                'eta': req.eta,
+            }
+            info(_app_trace.LOG_RECEIVED, context, extra={'data': context})
+
         bucket = None
         eta = None
         if req.eta: