Add tags to test_dual_write

high-performance-spark · Sep 24, 2023 · ed634cc · ed634cc
1 parent f35b345
commit ed634cc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/python/examples/test_dual_write.py b/python/examples/test_dual_write.py
@@ -1,6 +1,7 @@
 import os
 import tempfile
 
+#tag::test[]
 from sparktestingbase.sqltestcase import SQLTestCase
 from pyspark.sql.functions import current_timestamp
 from pyspark.sql.types import Row
@@ -21,3 +22,4 @@ def test_actual_dual_write(self):
         df1 = self.sqlCtx.read.format("parquet").load(p1)
         df2 = self.sqlCtx.read.format("parquet").load(p2)
         self.assertDataFrameEqual(df2.select("times"), df1, 0.1)
+#end::test[]