AHjLXddlmZddlmZer ddlmZddlmZdZd d dZ d d dZ d d Z y)) annotations) TYPE_CHECKING)Redis) BaseWorkerz rq:suspendedNc|j5}||j||jt|j dcdddS#1swYyxYw)a.Checks whether a Worker is suspended on a given connection PS: pipeline returns a list of responses Ref: https://github.com/andymccurdy/redis-py#pipelines Args: connection (Redis): The Redis Connection worker (Optional[Worker], optional): The Worker. Defaults to None. N)pipeline)r heartbeatexistsWORKERS_SUSPENDEDexecute) connectionworkerrs E/root/tools/cai/cai_env/lib/python3.12/site-packages/rq/suspension.py is_suspendedrs\    &(     h  /)*!"% &&&s r!s+" $# & 20r