Submodules

fito.ioc module

class fito.ioc.ApplicationContext(objects)[source]

Bases: object

alias(key, object_name)[source]
cache = DictDataStore()
get
AutosavedFunction fields:
args_specifications = KwargsField(default={}) cache_on = PrimitiveField() method_type = PrimitiveField(0, default=None) out_name = PrimitiveField(default=None) out_type = PrimitiveField(default=<class ‘fito.operations.operation.Operation’>)
classmethod load(*fnames)[source]
classmethod load_from_strings(strings, paths=None)[source]
resolve(obj)[source]
fito.ioc.recursive_load(strings, paths=None)[source]

Load strings or file contents :param strings: Represents yaml strings :param paths: Optionally context paths for each string, used for solving imports :return: an instance of ApplicationContext

fito.operation_runner module

class fito.operation_runner.FifoCache(size=500, verbose=False)[source]

Bases: object

Fifo caching strategy It is useful when there are operations that are costly to execute and you might need the result near in the future for computing another spec

get(spec)[source]
remove(spec)[source]
set(spec, value)[source]
class fito.operation_runner.OperationRunner(*args, **kwargs)[source]

Bases: fito.specs.base.Spec

OperationRunner fields:
execute_cache_size = NumericField(default=0) force = PrimitiveField(default=False, serialize=False) verbose = PrimitiveField(default=False)
alias(**kwargs)[source]

Same as self.replace, but keeps the same execute_cache

execute(operation, force=False)[source]

Executes an operation using this data store as input If this data store was configured to use an execute cache, it will be used

Parameters:force – Whether to ignore the current cached value of this operation
execute_cache_size = NumericField(default=0)
force = PrimitiveField(default=False, serialize=False)
verbose = PrimitiveField(default=False)

Module contents