wassname/catalyst
1
0
Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-06-29 11:49:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

Adds _ prefix to decorate_source to imply internal usage.

Browse Source
This commit is contained in:
Eddie Hebert
2013-01-07 13:03:12 -05:00
parent fc03e80cdf
commit ee02ff6445
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zipline/gens/composites.py
+2 -2
View File
@@ -16,7 +16,7 @@
import heapq
def decorate_source(source):
def _decorate_source(source):
for message in source:
yield ((message.dt, message.source_id), message)
@@ -26,7 +26,7 @@ def date_sorted_sources(*sources):
Takes an iterable of sources, generating namestrings and
piping their output into date_sort.
"""
sorted_stream = heapq.merge(*(decorate_source(s) for s in sources))
sorted_stream = heapq.merge(*(_decorate_source(s) for s in sources))
# Strip out key decoration
for _, message in sorted_stream: