tethys.core.sessions.sess_zero

Module Contents

tethys.core.sessions.sess_zero.log

class tethys.core.sessions.sess_zero.ZeroSession(network: Union['ZeroNetwork', str], parent: ZeroSession = None, **kwargs)

Bases: tethys.core.regobjs.regobj_zero.ZeroRegistrableObject, tethys.core.sessions.sess_base.SessionBase

The Session entity class of the Zero generation. The ZeroSession is a context for the streams.

Parameters

• network (ZeroNetwork) – The network used to run streams in the session scope.

• parent (ZeroSession) – The parent session

SOFT_CLOSING_MODE = <soft>

HARD_CLOSING_MODE = <hard>

INSTANT_CLOSING_MODE = <instant>

CLASS_PATH = /sessions/

ZeroSession instances collection path in the repository

FIELDS_SCHEMA

ZeroSession fields validators

__setattr__(self, key, value)

Implement setattr(self, name, value).

add_child(self, child: ZeroSession)

remove_child(self, child: ZeroSession)

get_children_dict(self)

open(self, **kwargs) → 'ZeroSession'

This method changes the ZeroSession station to closed=False.

Returns

self object

Return type

ZeroSession

close(self, mode: str = None) → 'ZeroSession'

This method changes the ZeroSession station to closing_mode=mode. All children also will be closed.

Parameters

mode (str) – closing mode determines the mode of closing streams (default: INSTANT_CLOSING_MODE)

Returns

self object

Return type

ZeroSession

send(self, data_packet: Any, many: bool = False, **kwargs)

This method sends data_packet(s) to the input nodes.

Parameters

• data_packet – any data object or list of the data objects (with many=True)

• many (bool) – if many=True then data_packet’s elements will be sent one-by-one.

refresh(self, **kwargs) → Union['ZeroSession', None]

Reload entity from the repository (without cache). Also this method updates streams and sessions states according to the closing mode.

Returns

return ZeroSession instance or None (when error like NotFound)

Return type

ZeroSession or None

__enter__(self) → 'ZeroSession'

__exit__(self, exc_type, exc_val, exc_tb)