CODEWITHSUNDEEP
djangopython-3.xdjango-channels
Pedro Rojas Gavidia
Pedro Rojas Gavidia

Reputation: 47

Channel Worker crash: how to do some task before crash?

For debugging purposes, I need to do a task (send an email) when some Channel Workers stops for an error.

I don't find a closure method that I could edit to add mi task in the SyncConsumer or AsyncConsumer.

channels==2.2.0 channels-redis==2.4.0

Upvotes: 0

Views: 58

Answers (1)

Matthaus Woolard
Matthaus Woolard

Reputation: 2408

For a completely generic approach:

You can try overriding the Consumers __call__ method

async def __call__(self, receive, send):

     try: 
         await super().__call__(receive, send):
     except:
         .... do your stuff
         raise

Upvotes: 1

Related Questions