MCPcopy
hub / github.com/celery/celery / save_result

Function save_result

t/unit/tasks/test_result.py:34–45  ·  view source on GitHub ↗
(app, task)

Source from the content-addressed store, hash-verified

32
33
34def save_result(app, task):
35 traceback = task.get('traceback') or 'Some traceback'
36 if task['state'] == states.SUCCESS:
37 app.backend.mark_as_done(task['id'], task['result'])
38 elif task['state'] == states.RETRY:
39 app.backend.mark_as_retry(
40 task['id'], task['result'], traceback=traceback,
41 )
42 else:
43 app.backend.mark_as_failure(
44 task['id'], task['result'], traceback=traceback,
45 )
46
47
48def make_mock_group(app, size=10):

Callers 3

make_mock_groupFunction · 0.85
setup_methodMethod · 0.85
setup_methodMethod · 0.85

Calls 4

mark_as_doneMethod · 0.80
mark_as_retryMethod · 0.80
mark_as_failureMethod · 0.80
getMethod · 0.45

Tested by

no test coverage detected