@@ -1,6 +1,7 @@
 | 
			
		||||
from concurrent.futures import ThreadPoolExecutor
 | 
			
		||||
import datetime
 | 
			
		||||
import os
 | 
			
		||||
import traceback
 | 
			
		||||
import zoneinfo
 | 
			
		||||
import requests
 | 
			
		||||
import time
 | 
			
		||||
@@ -55,6 +56,7 @@ class TasksHandlerMixin:
 | 
			
		||||
                success = True
 | 
			
		||||
            except Exception as exc:
 | 
			
		||||
                print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}')
 | 
			
		||||
                traceback.print_exc()
 | 
			
		||||
                success = False
 | 
			
		||||
            end = datetime.datetime.now(zoneinfo.ZoneInfo("Europe/Moscow"))
 | 
			
		||||
            if success:
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user