MCPcopy
hub / github.com/celery/celery / _close

Method _close

celery/worker/consumer/events.py:54–65  ·  view source on GitHub ↗
(self, c)

Source from the content-addressed store, hash-verified

52 pass
53
54 def _close(self, c):
55 if c.event_dispatcher:
56 dispatcher = c.event_dispatcher
57 # remember changes from remote control commands:
58 self.groups = dispatcher.groups
59
60 # close custom connection
61 if dispatcher.connection:
62 ignore_errors(c, dispatcher.connection.close)
63 ignore_errors(c, dispatcher.close)
64 c.event_dispatcher = None
65 return dispatcher
66
67 def shutdown(self, c):
68 self._close(c)

Callers 2

startMethod · 0.95
shutdownMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected