Skip to content

Commit

Permalink
ignore rd.core.sync-status schema in tests
Browse files Browse the repository at this point in the history
--HG--
extra : rebase_source : d852cecab232154bc7e293174be81ab4fc3b4bee
  • Loading branch information
mhammond committed Feb 9, 2010
1 parent e399050 commit 57274f6
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions server/python/raindrop/tests/pipeline/test_simple.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,14 +38,13 @@ def process_doc(self):

def get_last_by_seq(self, n=1):
def extract_rows(result):
ignore_schemas = ['rd.core.workqueue-state', 'rd.core.sync-status']
rows = result['rows']
ret = []
for row in rows:
if 'doc' in row and 'rd_schema_id' in row['doc']:
# If we are using a 'chasing' pipeline, then we can
# expect some 'state' docs to get in the way...
if self.use_backlog_processor and \
row['doc']['rd_schema_id']=='rd.core.workqueue-state':
# Ignore certain other schemas which may get in the way
if row['doc']['rd_schema_id'] in ignore_schemas:
continue
ret.append(row)
if len(ret)>=n:
Expand Down

0 comments on commit 57274f6

Please sign in to comment.