Переглянути джерело

Remove celery.worker.revoke.revoke (moved to celery.task.revoke)

Ask Solem 15 роки тому
батько
коміт
e111b10c59
1 змінених файлів з 0 додано та 10 видалено
  1. 0 10
      celery/worker/revoke.py

+ 0 - 10
celery/worker/revoke.py

@@ -37,16 +37,6 @@ class RevokeRegistry(UserDict):
         return sorted(self.items(), key=lambda (uuid, when): when)[0]
         return sorted(self.items(), key=lambda (uuid, when): when)[0]
 
 
 
 
-def revoke(uuid, connection=None):
-    conn = connection or DjangoBrokerConnection()
-    close_connection = not connection and conn.close or noop
-
-    broadcast = BroadcastPublisher(conn)
-    try:
-        broadcast.send({"revoke": uuid})
-    finally:
-        broadcast.close()
-        close_connection()
 
 
 revoked = RevokeRegistry()
 revoked = RevokeRegistry()