Update task.py get_custom_headers missing 'compression' key (#8633)

celery · Nov 19, 2023 · ca1dfbd · ca1dfbd
1 parent 709c5e7
commit ca1dfbd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/celery/app/task.py b/celery/app/task.py
@@ -104,7 +104,7 @@ def __init__(self, *args, **kwargs):
     def _get_custom_headers(self, *args, **kwargs):
         headers = {}
         headers.update(*args, **kwargs)
-        celery_keys = {*Context.__dict__.keys(), 'lang', 'task', 'argsrepr', 'kwargsrepr'}
+        celery_keys = {*Context.__dict__.keys(), 'lang', 'task', 'argsrepr', 'kwargsrepr', 'compression'}
         for key in celery_keys:
             headers.pop(key, None)
         if not headers: