conftest.py 625 B

1234567891011121314151617181920212223
  1. import json
  2. import pytest
  3. @pytest.fixture
  4. def message_stub():
  5. def make_message(**kwargs):
  6. return json.dumps(
  7. {
  8. "JobId": "1234",
  9. "Object": "s3://bucket/path/basic.parquet",
  10. "Columns": [{"Column": "customer_id"}],
  11. "CompositeColumns": [],
  12. "DeleteOldVersions": False,
  13. "IgnoreObjectNotFoundExceptions": False,
  14. "Format": "parquet",
  15. "Manifest": "s3://temp-bucket/manifests/1234/dm54321/manifest.json",
  16. **kwargs,
  17. }
  18. )
  19. return make_message