(stream, raw_data, ctx)
| 99 | |
| 100 | |
| 101 | def test_collect_data(stream, raw_data, ctx): |
| 102 | gen = stream.collector.run(ctx) |
| 103 | list(gen) |
| 104 | |
| 105 | with Session(ctx.engine) as session: |
| 106 | raw_model = stream.raw_model(session) |
| 107 | all_raw = [json.loads(r.data) for r in session.query(raw_model).all()] |
| 108 | assert all_raw == raw_data |
| 109 | |
| 110 | |
| 111 | def test_extract_data(stream, raw_data, ctx): |