Function validate_upload

test/aws-localstack/mzcompose.py:277–286

(upload, expected_output_set)

        )

        def validate_upload(upload, expected_output_set):
            assert len(upload["Contents"]) > 0
            output_lines = set()
            for obj in upload["Contents"]:
                assert obj["Key"].endswith(".csv")
                key = obj["Key"]
                object_response = s3_client.get_object(Bucket=bucket_name, Key=key)
                body = object_response["Body"].read().decode("utf-8")
                output_lines.update(body.splitlines())
            assert output_lines == expected_output_set

        # asserting the uploaded files
        date = c.sql_query("SELECT TO_CHAR(now(), 'YYYY-MM-DD')")[0][0]