vein.sources.files package¶

Submodules¶

vein.sources.files.file_state_tracker module¶

vein.sources.files.ini module¶

vein.sources.files.json module¶

vein.sources.files.yaml module¶

class vein.sources.files.yaml.YamlFileReader(file_path: PathLike, mode: str = 'r', encoding: str = 'utf-8', *args, **kwargs)[source]¶

Bases: AbstractFileReader

process_raw_stream(stream: IO[Any]) Any[source]¶

Module contents¶

vein.sources.files.from_ini(file_path: PathLike, mode: str = 'r', encoding: str = 'utf-8', use_cache: bool = True, retry: bool = False, backoff_policy: BackoffPolicy | None = None, cache: Cache | None = None) LiveFlowItem[source]¶
vein.sources.files.from_json(file_path: PathLike, mode: str = 'r', encoding: str = 'utf-8', use_cache: bool = True, retry: bool = False, backoff_policy: BackoffPolicy | None = None, cache: Cache | None = None) LiveFlowItem[source]¶
vein.sources.files.from_yaml(file_path: PathLike, mode: str = 'r', encoding: str = 'utf-8')[source]¶