Skip to content

Commit db7936b

Browse files
committed
Removed hack from development, now that the feature works as expected
1 parent 00ead67 commit db7936b

1 file changed

Lines changed: 0 additions & 12 deletions

File tree

celery/canvas.py

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -643,12 +643,6 @@ def stamp_links(self, visitor, **headers):
643643
visitor_headers = visitor.on_callback(link, **headers) or {}
644644
headers = self._stamp_headers(visitor_headers, **headers)
645645
link.stamp(visitor=visitor, **headers)
646-
# Stamping a link to a signature with previous stamps
647-
# may result in missing stamps in the link options, if the linking
648-
# was done AFTER the stamping of the signature
649-
for stamp in link.options.get('stamped_headers', []):
650-
if stamp in self.options and stamp not in link.options:
651-
link.options[stamp] = self.options[stamp]
652646

653647
# Stamp all of the errbacks of this signature
654648
headers = deepcopy(non_visitor_headers)
@@ -659,12 +653,6 @@ def stamp_links(self, visitor, **headers):
659653
visitor_headers = visitor.on_errback(link, **headers) or {}
660654
headers = self._stamp_headers(visitor_headers, **headers)
661655
link.stamp(visitor=visitor, **headers)
662-
# Stamping a link to a signature with previous stamps
663-
# may result in missing stamps in the link options, if the linking
664-
# was done AFTER the stamping of the signature
665-
for stamp in link.options.get('stamped_headers', []):
666-
if stamp in self.options and stamp not in link.options:
667-
link.options[stamp] = self.options[stamp]
668656

669657
def _with_list_option(self, key):
670658
"""Gets the value at the given self.options[key] as a list.

0 commit comments

Comments
 (0)