MCPcopy
hub / github.com/celery/celery / add_trail

Method add_trail

celery/app/task.py:1149–1152  ·  view source on GitHub ↗
(self, result)

Source from the content-addressed store, hash-verified

1147 raise Ignore('Replaced by new task')
1148
1149 def add_trail(self, result):
1150 if self.trail:
1151 self.request.children.append(result)
1152 return result
1153
1154 def push_request(self, *args, **kwargs):
1155 self.request_stack.push(Context(*args, **{**self.request.__dict__, **kwargs}))

Callers 4

apply_asyncMethod · 0.80
send_taskMethod · 0.80
groupFunction · 0.80

Calls

no outgoing calls

Tested by 1