fito.operations package

Submodules

fito.operations.decorate module

fito.operations.decorate.GenericDecorator

Abstracts all the boilerplate required to build a decorator that works on functions, instance methods and class methods

Parameters:method_type – if is None, the decorated function is assumed to be a function, otherwise it is assumed to be a method. If method_type == ‘instance’ the function is assumed to be an instance method otherwise a classmethod

fito.operations.decorate.as_operation

Creates an operation from a callable :param out_type: Base class of the operation to be built. Defaults to Operation :param out_name: Name of the class to be built, deafults to the decorated function name.

fito.operations.decorate.get_default_values(f_spec)

Returns a mapping from a function spec (output of inspect.getargspec)

fito.operations.decorate.operation_from_func(to_wrap, func_to_execute, out_type, out_name, args_specifications, f_spec=None, method_type=None, first_arg=None, cache_on=None)

In the case of methods, to_wrap is not the same to func_to_execute :param to_wrap: See GenericDecorator.create_decorated for an explanation :param func_to_execute: See GenericDecorator.create_decorated for an explanation :param cache_on: A data store onto which the operation should be cached :return:

fito.operations.decorate.print_fields_from_func(callable)

fito.operations.dependencies module

class fito.operations.dependencies.DependencyGraph

Bases: object

Main class to both manipulate the graph and inherit to get cool graph powers

static add_dependency(source, target)

Source depends on target :return:

dependency_graph = {}

static get_dependency_clausure(*classes_or_instances, **kwargs)

static get_dependency_graph()

Converts this guy to a networkx graph to easily perform crazy computations with this graph :return:

static get_direct_dependencies(klass)

static has_dependencies(klass)

fito.operations.dependencies.depends_on(thing)

Main decorator to tie things together :param thing: What you wanna tie with see pipeline.py or english_proficiency.py for examples

fito.operations.dependencies.get_subclasses(cls)

fito.operations.operation module

class fito.operations.operation.MemoryObject(*args, **kwargs)

Bases: fito.operations.operation.Operation

MemoryObject fields:

obj = PrimitiveField(0) out_data_store = BaseSpecField(default=None, serialize=False)

apply(runner)

obj = PrimitiveField(0)

to_dict(include_all=False)

class fito.operations.operation.Operation(*args, **kwargs)

Bases: fito.specs.base.Spec

Operation fields:

out_data_store = BaseSpecField(default=None, serialize=False)

apply(runner)

default_data_store = None

execute(force=False)

get_out_data_store()

out_data_store = BaseSpecField(default=None, serialize=False)

fito.operations.operation.OperationField(pos=None, default=<object object>, base_type=None)

fito.operations.series module

Module contents