Module Expr Str ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Call NameLoad NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Return For NameStore Call AttributeLoad NameLoad attr NameLoad body Expr Yield Call NameLoad NameLoad handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults kwarg body Expr Str FunctionDef arguments args NameParam defaults body TryExcept body If Call AttributeLoad NameLoad attr NameLoad body For NameStore Call AttributeLoad NameLoad attr NameLoad body Expr Yield NameLoad handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad decorator_list For NameStore NameLoad body If Call NameLoad NameLoad NameLoad body Raise NameLoad Assign NameStore ListLoad For NameStore NameLoad body For NameStore Call NameLoad NameLoad body Assign NameStore Call NameLoad NameLoad NameLoad If CompareIsNot NameLoad NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad If NameLoad body Return Call NameLoad NameLoad Return ListLoad decorator_list
N/A N/A Utilities for ls()ing and cat()ing logs without raising exceptions. logging getLogger mrjob.py2 to_string ids _sort_by_recency N/A log N/A getLogger __name__ _cat_log N/A N/A fs path N/A N/A N/A fs.cat() the given log, converting lines to strings, and logging
    errors. N/A N/A N/A N/A N/A N/A fs exists path N/A N/A N/A line N/A N/A fs cat path N/A N/A N/A N/A to_string line N/A N/A N/A IOError N/A e N/A N/A N/A N/A log warning N/A couldn't cat() %s: %r N/A path e N/A _ls_logs N/A N/A fs log_dir_stream matcher N/A kwargs N/A N/A Return a list matches against log files. Used to implement
    ``_ls_*_logs()`` functions.

    This yields dictionaries with ``path`` set to matching log path, and
    other information (e.g. corresponding job_id) returned by *matcher*

    *fs* is a :py:class:`mrjob.fs.Filesystem`

    *log_dir_stream* is a sequence of lists of log dirs. The idea is that
    there may be copies of the same logs in multiple places (e.g.
    on S3 and by SSHing into nodes) and we want to list them all without
    finding duplicate copies. This function will go through the lists of
    log dirs in turn, stopping if it finds any matches from a list.

    *matcher* is a function that takes (log_path, **kwargs)
    and returns either None (no match) or a dictionary with information
    about the path (e.g. the corresponding job_id). It's okay to return
    an empty dict.
     _fs_ls N/A N/A path N/A N/A N/A N/A N/A N/A N/A fs exists log_dir N/A N/A path N/A N/A fs ls log_dir N/A N/A N/A path N/A N/A N/A IOError N/A e N/A N/A N/A N/A log warning N/A couldn't ls() %s: %r N/A log_dir e N/A N/A log_dirs log_dir_stream N/A N/A N/A isinstance log_dirs str N/A N/A TypeError N/A matches N/A N/A log_dir log_dirs N/A N/A path N/A _fs_ls log_dir N/A N/A m N/A matcher path kwargs N/A N/A m None N/A N/A N/A m N/A path path N/A N/A N/A matches append m N/A matches N/A N/A N/A _sort_by_recency matches N/A N/A N/A