Merge branch 'development'

esakik · esakik · commit 780e219a635d · 2024-07-15T19:08:24.000+09:00
diff --git a/.gitignore b/.gitignore
@@ -127,3 +127,9 @@ dmypy.json
 
 # Pyre type checker
 .pyre/
+
+# PyCharm
+.idea/
+
+# Output files
+output/
diff --git a/examples/write_records_pipeline.py b/examples/write_records_pipeline.py
@@ -40,7 +40,7 @@ def run():
     (
         p
         | "ReadFromInMemory"
-        >> beam.Create([{"name": "test data3"}, {"name": "test data4"}])
+        >> beam.Create([{"name": "test data6", "date": "2020-06-06"}, {"name": "test data7", "date": "2020-06-07"}])
         | "NoTransform" >> beam.Map(lambda e: e)
         | "WriteToMySQL" >> write_to_mysql
     )

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ def run():`
`40`	`40`	`(`
`41`	`41`	`p`
`42`	`42`	`\| "ReadFromInMemory"`
`43`		`- >> beam.Create([{"name": "test data3"}, {"name": "test data4"}])`
	`43`	`+ >> beam.Create([{"name": "test data6", "date": "2020-06-06"}, {"name": "test data7", "date": "2020-06-07"}])`
`44`	`44`	`\| "NoTransform" >> beam.Map(lambda e: e)`
`45`	`45`	`\| "WriteToMySQL" >> write_to_mysql`
`46`	`46`	`)`