Module ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults Str NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Return Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Num NameLoad body Expr Str Assign NameStore IfExp CompareLt NameLoad Num NameLoad BinOpAdd Call NameLoad NameLoad If CompareIsNot NameLoad NameLoad body Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Return Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Assign NameStore IfExp CompareIsNot NameLoad NameLoad NameLoad AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Assign NameStore IfExp CompareIsNot NameLoad NameLoad NameLoad Call NameLoad Return ListComp Call NameLoad NameLoad comprehension NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Num NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults Num Num body Expr Str Expr Call AttributeLoad NameLoad attr Return ListComp Call NameLoad NameLoad comprehension NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults Str NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad Str attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Assign NameStore IfExp CompareIsNot NameLoad NameLoad NameLoad Call NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad If NameLoad body Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr With Call AttributeLoad AttributeLoad NameLoad attr attr NameStore body For NameStore NameLoad body TryExcept body Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad handlers ExceptHandler type NameLoad body Pass Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num NameLoad Expr Call AttributeLoad NameLoad attr Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults Str NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad Str attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Assign NameStore IfExp CompareIsNot NameLoad NameLoad NameLoad Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Num NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults Str NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad Str attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Pass decorator_list decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list
N/A compat as_text connections resolve_connection exceptions NoSuchJobError job Job JobStatus queue FailedQueue utils current_timestamp BaseRegistry N/A object N/A N/A 
    Base implementation of a job registry, implemented in Redis sorted set.
    Each job is stored as a key in the registry, scored by expiration time
    (unix timestamp).
     __init__ N/A N/A self name connection N/A default None N/A N/A N/A self name name N/A N/A self connection N/A resolve_connection connection N/A __len__ N/A N/A self N/A N/A N/A Returns the number of jobs in this registry N/A N/A self count N/A count N/A N/A self N/A N/A N/A Returns the number of jobs in this registry N/A N/A N/A self cleanup N/A N/A N/A N/A self connection zcard N/A self key N/A property add N/A N/A self job ttl pipeline N/A 0 None N/A N/A Adds a job to a registry with expiry time of now + ttl. N/A score N/A N/A ttl 0 ttl N/A N/A current_timestamp ttl N/A N/A pipeline None N/A N/A N/A N/A pipeline zadd N/A self key score N/A job id N/A N/A N/A N/A self connection _zadd N/A self key score N/A job id N/A remove N/A N/A self job pipeline N/A None N/A N/A connection N/A N/A pipeline None pipeline N/A self connection N/A N/A N/A connection zrem N/A self key N/A job id N/A get_expired_job_ids N/A N/A self timestamp N/A None N/A N/A Returns job ids whose score are less than current timestamp.

        Returns ids for jobs with an expiry time earlier than timestamp,
        specified as seconds since the Unix epoch. timestamp defaults to call
        time if unspecified.
         N/A score N/A N/A timestamp None timestamp N/A current_timestamp N/A N/A N/A as_text job_id N/A job_id N/A N/A N/A self connection zrangebyscore N/A self key 0 score N/A get_job_ids N/A N/A self start end N/A 0 -1 N/A N/A Returns list of all job ids. N/A N/A N/A self cleanup N/A N/A N/A as_text job_id N/A job_id N/A N/A N/A self connection zrange N/A self key start end N/A N/A StartedJobRegistry N/A BaseRegistry N/A N/A 
    Registry of currently executing jobs. Each queue maintains a
    StartedJobRegistry. Jobs in this registry are ones that are currently
    being executed.

    Jobs are added to registry right before they are executed and removed
    right after completion (success or failure).
     __init__ N/A N/A self name connection N/A default None N/A N/A N/A N/A N/A super StartedJobRegistry self __init__ name connection N/A N/A self key N/A N/A rq:wip:{0} format name N/A cleanup N/A N/A self timestamp N/A None N/A N/A Remove expired jobs from registry and add them to FailedQueue.

        Removes jobs with an expiry time earlier than timestamp, specified as
        seconds since the Unix epoch. timestamp defaults to call time if
        unspecified. Removed jobs are added to the global failed job queue.
         N/A score N/A N/A timestamp None timestamp N/A current_timestamp N/A job_ids N/A N/A self get_expired_job_ids score N/A job_ids N/A N/A failed_queue N/A FailedQueue connection N/A self connection N/A N/A N/A N/A self connection pipeline pipeline N/A N/A job_id job_ids N/A N/A N/A N/A job N/A N/A Job fetch job_id connection N/A self connection N/A N/A N/A job set_status N/A JobStatus FAILED N/A N/A N/A job save pipeline pipeline N/A N/A N/A failed_queue push_job_id job_id pipeline pipeline N/A N/A N/A NoSuchJobError N/A N/A N/A N/A N/A pipeline zremrangebyscore N/A self key 0 score N/A N/A N/A pipeline execute N/A job_ids N/A N/A FinishedJobRegistry N/A BaseRegistry N/A N/A 
    Registry of jobs that have been completed. Jobs are added to this
    registry after they have successfully completed for monitoring purposes.
     __init__ N/A N/A self name connection N/A default None N/A N/A N/A N/A N/A super FinishedJobRegistry self __init__ name connection N/A N/A self key N/A N/A rq:finished:{0} format name N/A cleanup N/A N/A self timestamp N/A None N/A N/A Remove expired jobs from registry.

        Removes jobs with an expiry time earlier than timestamp, specified as
        seconds since the Unix epoch. timestamp defaults to call time if
        unspecified.
         N/A score N/A N/A timestamp None timestamp N/A current_timestamp N/A N/A N/A N/A self connection zremrangebyscore N/A self key 0 score N/A N/A DeferredJobRegistry N/A BaseRegistry N/A N/A 
    Registry of deferred jobs (waiting for another job to finish).
     __init__ N/A N/A self name connection N/A default None N/A N/A N/A N/A N/A super DeferredJobRegistry self __init__ name connection N/A N/A self key N/A N/A rq:deferred:{0} format name N/A cleanup N/A N/A self N/A N/A N/A This method is only here to prevent errors because this method is
        automatically called by `count()` and `get_job_ids()` methods
        implemented in BaseRegistry. N/A N/A N/A clean_registries N/A N/A queue N/A N/A N/A Cleans StartedJobRegistry and FinishedJobRegistry of a queue. N/A registry N/A FinishedJobRegistry name N/A queue name connection N/A queue connection N/A N/A N/A registry cleanup N/A registry N/A StartedJobRegistry name N/A queue name connection N/A queue connection N/A N/A N/A registry cleanup N/A