diff --git a/zipline/gens/composites.py b/zipline/gens/composites.py index 88976bb0..4d448641 100644 --- a/zipline/gens/composites.py +++ b/zipline/gens/composites.py @@ -31,6 +31,7 @@ def date_sorted_sources(*sources): # Guarantee the flat stream will be sorted by date, using source_id as # tie-breaker, which is fully deterministic (given deterministic string # representation for all args/kwargs) + return date_sort(stream_in, names)