Skip to content

Commit 386cd66

Browse files
committed
Format with black
1 parent e8e82b2 commit 386cd66

File tree

2 files changed

+13
-9
lines changed

2 files changed

+13
-9
lines changed

examples/string_processing_pipeline.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,27 +1,28 @@
11
import asyncio
22
import flowbase
33

4+
45
def main():
56
net = flowbase.Network()
67

78
# Initialize components
89
hisayer = HiSayer()
9-
net.add_process('hisayer', hisayer)
10+
net.add_process("hisayer", hisayer)
1011

1112
splitter = StringSplitter()
12-
net.add_process('hisayer', splitter)
13+
net.add_process("hisayer", splitter)
1314

1415
lowercaser = LowerCaser()
15-
net.add_process('hisayer', lowercaser)
16+
net.add_process("hisayer", lowercaser)
1617

1718
uppercaser = UpperCaser()
18-
net.add_process('hisayer', uppercaser)
19+
net.add_process("hisayer", uppercaser)
1920

2021
stringjoiner = StringJoiner()
21-
net.add_process('hisayer', stringjoiner)
22+
net.add_process("hisayer", stringjoiner)
2223

2324
printer = Printer()
24-
net.add_process('hisayer', printer)
25+
net.add_process("hisayer", printer)
2526

2627
# Connect network
2728
splitter.in_lines = hisayer.out_lines

flowbase/flowbase.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,16 @@
1-
'''
1+
"""
22
Copyright (c) 2020 Samuel Lampa <samuel.lampa@rilnet.com>
3-
'''
3+
"""
44

55
import asyncio
66
import typing
77

8+
89
class Process:
910
def run(self):
10-
raise NotImplementedError(f'str(type(self)) can not be used directly, but must be subclassed')
11+
raise NotImplementedError(
12+
f"str(type(self)) can not be used directly, but must be subclassed"
13+
)
1114

1215

1316
class Network(Process):

0 commit comments

Comments
 (0)