removed spammy log lines.

This commit is contained in:
fawce
2012-08-17 18:36:05 -04:00
parent c911dca4d2
commit 7696393179
+2 -4
View File
@@ -27,12 +27,11 @@ def date_sort(stream_in, source_ids):
sources[id] = deque()
# Process incoming streams.
log.info('Sorting first message')
for message in stream_in:
# Incoming messages should be the output of DATASOURCE_UNFRAME.
assert_datasource_unframe_protocol(message), \
"Bad message in date_sort: %s" % message
# Only allow messages from sources we expect.
assert message.source_id in sources, "Unexpected source: %s" % message
@@ -45,13 +44,12 @@ def date_sort(stream_in, source_ids):
message = pop_oldest(sources)
assert_sort_protocol(message)
yield message
# We should have only a done message left in each queue.
for queue in sources.itervalues():
assert len(queue) == 1, "Bad queue in date_sort on exit: %s" % queue
assert queue[0].dt == "DONE", \
"Bad last message in date_sort on exit: %s" % queue
log.info('Successfully finished Sorting')
def ready(sources):
"""