-
Notifications
You must be signed in to change notification settings - Fork 0
/
workflow.py
23 lines (15 loc) · 799 Bytes
/
workflow.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
from obsei.configuration import ObseiConfiguration
from dotenv import load_dotenv
load_dotenv()
obsei_configuration = ObseiConfiguration()
source_config = obsei_configuration.initialize_instance("source_config")
source = obsei_configuration.initialize_instance("source")
analyzer = obsei_configuration.initialize_instance("analyzer")
analyzer_config = obsei_configuration.initialize_instance("analyzer_config")
sink_config = obsei_configuration.initialize_instance("sink_config")
sink = obsei_configuration.initialize_instance("sink")
source_response_list = source.lookup(source_config)
analyzer_response_list = analyzer.analyze_input(
source_response_list=source_response_list, analyzer_config=analyzer_config
)
sink_response_list = sink.send_data(analyzer_response_list, sink_config)