elcflow package

Submodules

elcflow.base module

各个主要基础元件的定义,包含了函数/算子/数据/节点和边

class elcflow.base.ELCData(**kwargs)

基类：object

整个Graph上的数据, 不同数据对应了不同的序列化函数

get_data()

set_data(data)

class elcflow.base.ELCDataPlaceholder(**kwargs)

基类：elcflow.base.ELCNode

存数据的node

class elcflow.base.ELCEdge(**kwargs)

基类：object

to_dict()

update(**kwargs)

class elcflow.base.ELCFunction(**kwargs)

基类：object

算子使用的函数

class elcflow.base.ELCNode(**kwargs)

基类：object

节点: 主要应该规定输入和输出 输入按照名称来: UI上方便实现 输出可以说tuple(多个),但是会给他们名称

to_dict()

class elcflow.base.ELCOperator(**kwargs)

基类：elcflow.base.ELCNode

to_dict()

elcflow.base.register_elc_function(outputs, inputs=None, name=None, parameters=None)

elcflow.builtin_operators module

内置了一些算子,可以当作example

elcflow.defs module

用来enum常用的字符串变量

elcflow.graph module

实现了Graph的逻辑:包含运行、暂停、snapshot等功能

class elcflow.graph.ELCGraph(**kwargs)

基类：object

add_edge(edge)

参数:edge (ELCEdge) – 返回:

add_node(node)

参数:node (ELCNode) – 返回:

compile()

解析图并且生成序列

static convert_json_from_elc_to_nx()

static convert_json_from_nx_to_elc()

static convert_json_to_object(json_dict)

classmethod create_from_elc_json(elc_json, **kwargs)

execute(stop_node_id=None)

feed_data_dict(data_dict)

classmethod load(model_obj, model=None)

参数:

• model_obj (dict) –
• model (ELCGraph) –

返回:

plot(show=False, with_state=False)

set_state(state)

to_dict()

elcflow.helpers module

主要是帮助做序列化的函数,包含了对dataframe、numpy等一些格式的序列化

class elcflow.helpers.ELCJSONEncoder(*, skipkeys=False, ensure_ascii=True, check_circular=True, allow_nan=True, sort_keys=False, indent=None, separators=None, default=None)

基类：json.encoder.JSONEncoder

主要的序列化器,主要功能就是把一些类型拆成__elc_type__和__elc_data__,后者 用来记录数据,前者用来恢复数据的时候使用

default(obj)

Implement this method in a subclass such that it returns a serializable object for o, or calls the base implementation (to raise a TypeError).

For example, to support arbitrary iterators, you could implement default like this:

def default(self, o):
    try:
        iterable = iter(o)
    except TypeError:
        pass
    else:
        return list(iterable)
    # Let the base class default method raise the TypeError
    return JSONEncoder.default(self, o)

elcflow.helpers.json_parse(dict_obj)

TODO: 请注意: 暂时不支持如下的格式: {‘x’: {‘__elc_type__’: ‘’, ‘__elc_data__’: {‘__elc_type__’: ‘’,’__elc_data__’: ‘’}}} :param dict_obj: 一个plain的dict, 我们需要递归的把各个类型转回来 :type dict_obj: dict :return:

elcflow.helpers.json_stringify(dict_obj)

Module contents