MCPcopy
hub / github.com/celery/celery / terminate

Method terminate

t/unit/concurrency/test_prefork.py:152–153  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

150 self.joined = True
151
152 def terminate(self):
153 self.terminated = True
154
155 def terminate_job(self, *args, **kwargs):
156 pass

Callers 13

get_worker_error_messagesFunction · 0.45
test_rabbitmq_quorum_qos_visibility_raceFunction · 0.45
test_terminate__no_objMethod · 0.45
test_terminateMethod · 0.45
test_with_autoscaler_file_descriptor_safetyMethod · 0.45
test_with_file_descriptor_safetyMethod · 0.45
test_start__terminateMethod · 0.45
test_terminateMethod · 0.45
test_terminate__pool_refMethod · 0.45
test_terminate__task_startedMethod · 0.45
test_terminate__task_reservedMethod · 0.45
test_on_accepted_terminatesMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected