FilesExpand file tree

 master

/

pipeline.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

31 lines (23 loc) · 995 Bytes

 master

/

pipeline.py

Copy path

Top

File metadata and controls

• Code
• Blame

31 lines (23 loc) · 995 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

# Copyright (C) 2011 Jesus Leganes "piranna", piranna@gmail.com

#

# This module is part of python-sqlparse and is released under

# the BSD License: http://www.opensource.org/licenses/bsd-license.php.

from types import GeneratorType

class Pipeline(list):

"""Pipeline to process filters sequentially"""

def __call__(self, stream):

"""Run the pipeline

Return a static (non generator) version of the result

"""

# Run the stream over all the filters on the pipeline

for filter in self:

# Functions and callable objects (objects with '__call__' method)

if callable(filter):

stream = filter(stream)

# Normal filters (objects with 'process' method)

else:

stream = filter.process(None, stream)

# If last filter return a generator, staticalize it inside a list

if isinstance(stream, GeneratorType):

return list(stream)

return stream