MCPcopy
hub / github.com/celery/celery / start_strategy

Method start_strategy

celery/app/task.py:449–450  ·  view source on GitHub ↗
(self, app, consumer, **kwargs)

Source from the content-addressed store, hash-verified

447 raise NotImplementedError('Tasks must define the run method.')
448
449 def start_strategy(self, app, consumer, **kwargs):
450 return instantiate(self.Strategy, self, app, consumer, **kwargs)
451
452 def delay(self, *args, **kwargs):
453 """Star argument version of :meth:`apply_async`.

Callers 2

_contextMethod · 0.80
update_strategiesMethod · 0.80

Calls 1

instantiateFunction · 0.90

Tested by 1

_contextMethod · 0.64