refyre package#
Subpackages#
- refyre.cluster package
- Submodules
- refyre.cluster.Association module
- refyre.cluster.Broadcast module
- refyre.cluster.Cache module
- refyre.cluster.Cluster module
FileClusterFileCluster.GLOBAL_COUNTERFileCluster.all_clusters()FileCluster.cache()FileCluster.cached()FileCluster.cleanup()FileCluster.clone()FileCluster.clustersFileCluster.copy()FileCluster.decache()FileCluster.decompress()FileCluster.delete()FileCluster.dirs()FileCluster.filecount()FileCluster.filesize()FileCluster.filter()FileCluster.item()FileCluster.map()FileCluster.move()FileCluster.post()FileCluster.reduce()FileCluster.relink()FileCluster.rename()FileCluster.unlink()FileCluster.vals()FileCluster.wipe()FileCluster.zip()
handle_file_conflict()
- refyre.cluster.ClusterIterator module
- Module contents
- refyre.config package
- refyre.core package
- refyre.datastack package
- refyre.graph package
- refyre.reader package
- refyre.utils package
Submodules#
refyre.Refyre module#
- class refyre.Refyre.Refyre(input_specs=None, output_specs=None, variables=None)[source]#
Bases:
object- create_spec(spec_path, mode='cut', track=False)[source]#
Creates a spec given by the spec path
spec_path - filepath to the spec path mode: “cut”: Any files that are being transferred to create this spec will be cut from their place “copy”: Any files that are being transferred to create this spec will be duplicated from their original place
- step()[source]#
Reconstructs all the variables, generates / functions towards all directories with a ‘*s’ flag in the following ways, based on the flags below:
‘*wl’ - base write, write latest cluster in the pattern sequence
Updates to arch -
Need to maintain a “blueprint” fgraph, pre expansion AND current fgraph
During step, each directory is created / analyzed