Module Import alias Import alias ImportFrom alias identifier alias identifier alias alias alias alias alias alias alias alias alias alias alias ImportFrom alias alias alias ClassDef bases NameLoad body Expr Str Pass decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr IfExp CompareIs NameLoad NameLoad AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr IfExp CompareIs NameLoad NameLoad AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr IfExp CompareIs NameLoad NameLoad AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad If UnaryOpNot NameLoad body Expr Call AttributeLoad NameLoad attr TryExcept body Assign TupleStore AttributeStore NameLoad attr NameStore Call NameLoad NameLoad TryExcept body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad NameLoad Index Num AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr SubscriptLoad NameLoad Index Num Assign AttributeStore NameLoad attr SubscriptLoad NameLoad Index Num Assign AttributeStore NameLoad attr SubscriptLoad NameLoad Index Num Assign AttributeStore NameLoad attr SubscriptLoad NameLoad Index Num Assign AttributeStore NameLoad attr Call NameLoad SubscriptLoad NameLoad Slice Num handlers ExceptHandler type NameLoad name NameStore body Raise Call NameLoad AttributeLoad NameLoad attr Call AttributeLoad Str attr Call NameLoad NameLoad ExceptHandler type NameLoad name NameStore body Raise Call NameLoad AttributeLoad NameLoad attr Call AttributeLoad Str attr AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Num TryExcept body Assign AttributeStore NameLoad attr Call NameLoad AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Raise Call NameLoad AttributeLoad NameLoad attr Call AttributeLoad Str attr AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr TryExcept body Expr Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr handlers ExceptHandler type TupleLoad NameLoad NameLoad name NameStore body Assign AttributeStore NameLoad attr Call AttributeLoad Str attr ListLoad AttributeLoad NameLoad attr Call AttributeLoad Str attr AttributeLoad NameLoad attr Raise NameLoad handlers ExceptHandler type NameLoad name NameStore body TryFinally body Expr Call AttributeLoad NameLoad attr finalbody Expr Call AttributeLoad NameLoad attr Raise NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If BoolOpAnd Call NameLoad NameLoad Str Call NameLoad AttributeLoad NameLoad attr Str CompareIsNot AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr TryExcept body Assign AttributeStore NameLoad attr Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr handlers ExceptHandler type TupleLoad NameLoad NameLoad name NameStore body If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Raise Call NameLoad AttributeLoad NameLoad attr Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Raise Call NameLoad AttributeLoad NameLoad attr Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad NameLoad decorator_list decorator_list
N/A N/A errno N/A datetime N/A constants _c path fsq_path deconstruct FSQMalformedEntryError FSQTimeFmtError FSQWorkItemError FSQMaxTriesError FSQTTLExpiredError fail success done fail_tmp fail_perm internal rationalize_file wrap_io_os_err check_ttl_max_tries FSQEnqueueItem N/A object N/A N/A Stub for Streamable Enqueue object, e.g.

        foo = FSQEnqueueItem('foo', 'bar', 'baz', 'bang')
        try:
            for i in ['a', 'b', 'c']:
                foo.item.write(i)
            foo.commit()
        except Exception, e:
            foo.abort()
        finally:
            del foo
     N/A N/A FSQWorkItem N/A object N/A N/A An FSQWorkItem object.  FSQWorkItem stores an open and potentially
       exclusive-locked file to a work file as the attribute self.item, opened
       in read-only mode.

       FSQWorkItem is intended to a minimalist object, capable of reverse
       engineering to a C struct.  The C struct will support all attributes,
       but the methods will not be available, they will be available as
       include level functions taking a *WorkItem struct as their first
       argument.

       BEWARE: If you choose not to lock, the item you are working on may be
       worked on by others, and may be moved (on failure or success) out from
       underneath you.  Should you send lock=False, it is assumed you are
       guarenteeing concurrency of 1 on the queue through some other
       mechanism. __init__ N/A N/A self trg_queue item_id max_tries ttl lock no_open host N/A None None None False None N/A N/A Construct an FSQWorkItem object from an item_id (file-name), and
           queue-name.  The lock kwarg will override the default locking
           preference (taken from environment). N/A N/A self id item_id N/A N/A self queue trg_queue N/A N/A self max_tries N/A N/A max_tries None N/A _c FSQ_MAX_TRIES max_tries N/A N/A self ttl N/A N/A ttl None N/A _c FSQ_TTL ttl N/A N/A self lock N/A N/A lock None N/A _c FSQ_LOCK lock N/A N/A self item None N/A N/A self host host N/A N/A no_open N/A N/A N/A N/A self open N/A N/A N/A N/A N/A self delimiter arguments N/A deconstruct item_id N/A N/A N/A N/A self enqueued_at N/A N/A N/A datetime datetime strptime N/A arguments N/A 0 N/A _c FSQ_TIMEFMT N/A N/A self entropy N/A arguments N/A 1 N/A N/A self pid N/A arguments N/A 2 N/A N/A self hostname N/A arguments N/A 3 N/A N/A self tries N/A arguments N/A 4 N/A N/A self arguments N/A tuple N/A arguments N/A 5 N/A N/A N/A IndexError N/A e N/A N/A N/A FSQMalformedEntryError N/A errno EINVAL N/A N/A needed at least 4 arguments to unpack, got: {0} format N/A len arguments N/A N/A ValueError N/A e N/A N/A N/A FSQTimeFmtError N/A errno EINVAL N/A N/A invalid date string for strptime fmt {0}: {1} format N/A _c FSQ_TIMEFMT N/A arguments N/A 0 N/A N/A N/A N/A self tries N/A int N/A self tries N/A N/A N/A ValueError N/A e N/A N/A N/A FSQTimeFmtError N/A errno EINVAL N/A N/A tries must be an int, not {0}: {1} format N/A N/A N/A self tries __class__ __name__ N/A self tries N/A N/A N/A N/A check_ttl_max_tries N/A self tries N/A self enqueued_at N/A self max_tries N/A self ttl N/A N/A N/A N/A FSQMaxTriesError FSQTTLExpiredError N/A e N/A N/A N/A e strerror N/A N/A :  join N/A N/A e strerror N/A N/A for item {0}; failed permanently format N/A self id N/A e N/A N/A N/A Exception N/A e N/A N/A N/A N/A N/A N/A self fail_perm N/A N/A N/A N/A self close N/A e N/A __del__ N/A N/A self N/A N/A N/A Always close the file when the ref count drops to 0 N/A N/A N/A self close N/A close N/A N/A self N/A N/A N/A N/A N/A hasattr self item N/A hasattr N/A self item close N/A N/A self item None N/A N/A N/A N/A N/A self item close N/A open N/A N/A self N/A N/A N/A N/A N/A self close N/A N/A N/A N/A self item N/A rationalize_file N/A N/A fsq_path item N/A self queue N/A self id host N/A self host N/A _c FSQ_CHARSET lock N/A self lock N/A N/A N/A N/A OSError IOError N/A e N/A N/A N/A N/A e errno N/A errno ENOENT N/A N/A N/A FSQWorkItemError N/A e errno N/A N/A no such item in queue {0}: {1} format N/A self queue N/A self id N/A N/A FSQWorkItemError N/A e errno N/A wrap_io_os_err e N/A done N/A N/A self done_type N/A None N/A N/A Complete an item, either successfully or with failure N/A N/A done self done_type N/A success N/A N/A self N/A N/A N/A Complete an item successfully N/A N/A success self N/A fail N/A N/A self fail_type N/A None N/A N/A Fail this item either temporarily or permanently. N/A N/A fail self fail_type N/A fail_tmp N/A N/A self N/A N/A N/A Fail an item temporarily (either retry, or escalate to perm) N/A N/A fail_tmp self N/A fail_perm N/A N/A self N/A N/A N/A N/A fail_perm self N/A N/A