paulin/bonobo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

minor cleanups

Browse Source
This commit is contained in:
Romain Dorgueil
2017-09-30 11:50:34 +02:00
parent 9b3777f88d
commit b26dbc83cb
2 changed files with 0 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
bonobo/nodes/throttle.py
View File

@ -41,15 +41,12 @@ class RateLimited(Configurable):
@ContextProcessor @ContextProcessor
def bucket(self, context): def bucket(self, context):
print(context)
bucket = RateLimitBucket(self.initial, self.amount, self.period) bucket = RateLimitBucket(self.initial, self.amount, self.period)
bucket.start() bucket.start()
print(bucket)
yield bucket yield bucket
bucket.stop() bucket.stop()
bucket.join() bucket.join()
def call(self, bucket, *args, **kwargs): def call(self, bucket, *args, **kwargs):
print(bucket, args, kwargs)
bucket.wait() bucket.wait()
return self.handler(*args, **kwargs) return self.handler(*args, **kwargs)

8
bonobo/util/graphviz.py
View File

@ -1,8 +0,0 @@
def render_as_dot(graph):
"""
:param bonobo.Graph graph:
:return: str
"""
pass