o /i@@snddlmZmZerddlmZddlmZdZdddded fd d Zdddd ee fd dZ dddZ dS)) TYPE_CHECKINGOptional)Redis) BaseWorkerz rq:suspendedN connectionrworkerrcCsV|}|dur|j|d|t|dWdS1s$wYdS)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)rrrrM/var/www/html/flask_server/venv/lib/python3.10/site-packages/rq/suspension.py is_suspended s    $rttlcCs(|td|dur|t|dSdS)z Suspends. TTL of 0 will invalidate right away. Args: connection (Redis): The Redis connection to use.. ttl (Optional[int], optional): time to live in seconds. Defaults to `None` N)setr expire)rrrrrsuspends rcCs |tS)zW Resumes. Args: connection (Redis): The Redis connection to use.. )deleter )rrrrresume*s r)N)rr) typingrrredisr rq.workerrr rintrrrrrrs