import pytest from sample_validator import load_schema, validate_stream @pytest.mark.parametrize('report_url,schema_url', ( ( 'daily_activity_summary/sme_daily_activity_summary_20190812.csv', 'daily_activity_summary/v1/2019-06-01.json', ), )) def test_youtubemusic( s3_upload_schema, s3_upload_report, report_url, schema_url ): report_url = s3_upload_report(f'youtubemusic/{report_url}') schema_url = s3_upload_schema(f'youtubemusic/{schema_url}') result, log_info = validate_stream( load_schema(schema_url), report_url, 100, 0, ) assert result assert not log_info['errors'] assert not log_info['warnings']