MCPcopy
hub / github.com/celery/celery / chunks

Method chunks

celery/app/task.py:908–911  ·  view source on GitHub ↗

Create a :class:`~celery.canvas.chunks` task for this task.

(self, it, n)

Source from the content-addressed store, hash-verified

906 return self.signature(args, kwargs, immutable=True)
907
908 def chunks(self, it, n):
909 """Create a :class:`~celery.canvas.chunks` task for this task."""
910 from celery import chunks
911 return chunks(self.s(), it, n, app=self.app)
912
913 def map(self, it):
914 """Create a :class:`~celery.canvas.xmap` task from ``it``."""

Callers 3

test_chunksMethod · 0.80
test_chunksMethod · 0.80

Calls 2

sMethod · 0.95
chunksFunction · 0.90

Tested by 3

test_chunksMethod · 0.64
test_chunksMethod · 0.64