(self, dynamodb_client, scan_table)
| 295 | assert "category" not in item |
| 296 | |
| 297 | def test_scan_parallel(self, dynamodb_client, scan_table): |
| 298 | total_segments = 3 |
| 299 | all_items: list = [] |
| 300 | for seg in range(total_segments): |
| 301 | resp = dynamodb_client.scan( |
| 302 | TableName=scan_table, |
| 303 | Segment=seg, |
| 304 | TotalSegments=total_segments, |
| 305 | ) |
| 306 | all_items.extend(resp["Items"]) |
| 307 | assert len(all_items) == 13 |
| 308 | |
| 309 | def test_scan_segment_without_total(self, dynamodb_client, scan_table): |
| 310 | with pytest.raises(ClientError) as exc_info: |