[ci] apply automatic fixes

feldera-bot · ryzhyk · commit 38be652d4fc8 · 2025-11-14T22:41:10.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
diff --git a/demo/project_demo10-FraudDetectionDeltaLake/run.py b/demo/project_demo10-FraudDetectionDeltaLake/run.py
@@ -116,7 +116,7 @@ def main():
                     "mode": "snapshot",
                     "aws_skip_signature": "true",
                 },
-            }
+            },
         }
     ]
 
@@ -132,7 +132,7 @@ def main():
                     "aws_skip_signature": "true",
                     "timestamp_column": "unix_time",
                 },
-            }
+            },
         }
     ]
 
@@ -148,7 +148,7 @@ def main():
                         "mode": "truncate",
                     }
                     | s3_credentials,
-                }
+                },
             }
         ]
     else:
@@ -205,7 +205,7 @@ def main():
                     "mode": "snapshot",
                     "aws_skip_signature": "true",
                 },
-            }
+            },
         }
     ]
 
@@ -224,7 +224,7 @@ def main():
                     "timestamp_column": "unix_time",
                     "aws_skip_signature": "true",
                 },
-            }
+            },
         }
     ]
 
@@ -240,7 +240,7 @@ def main():
                         "mode": "truncate",
                     }
                     | s3_credentials,
-                }
+                },
             }
         ]
     else:
diff --git a/python/tests/runtime/test_spreadsheet.py b/python/tests/runtime/test_spreadsheet.py
@@ -6,18 +6,20 @@
 from feldera import PipelineBuilder
 from tests import TEST_CLIENT, unique_pipeline_name
 
+
 def make_value(id: int, raw: str, computed: str) -> dict:
     return {
         "id": id,
         "background": 0,
         "raw_value": raw,
         "computed_value": computed,
-        "insert_delete": 1
+        "insert_delete": 1,
     }
 
+
 class TestUDF(unittest.TestCase):
     def test_local(self):
-        dir = "../demo/packaged/sql/";
+        dir = "../demo/packaged/sql/"
         # Read the file ../demo/packaged/sql/10-spreadsheet.sql
         with open(dir + "10-spreadsheet.sql", "r") as f:
             sql = f.read()
@@ -27,8 +29,11 @@ def test_local(self):
             toml = f.read()
 
         pipeline = PipelineBuilder(
-            TEST_CLIENT, name=unique_pipeline_name("test_spreadsheet"), sql=sql, udf_rust=udfs,
-            udf_toml=toml
+            TEST_CLIENT,
+            name=unique_pipeline_name("test_spreadsheet"),
+            sql=sql,
+            udf_rust=udfs,
+            udf_toml=toml,
         ).create_or_replace()
 
         pipeline.start_paused()
@@ -57,13 +62,13 @@ def test_local(self):
             make_value(91, "=OR(1>1,1<>1)", "FALSE"),
             make_value(92, "={1,2,3}+{1,2,3}", "{2,4,6}"),
             make_value(93, "=DAYS(P1, P2)", "-182"),
-            make_value(117, "=AND(\"test\",\"True\", 1, true)", "TRUE"),
+            make_value(117, '=AND("test","True", 1, true)', "TRUE"),
             make_value(118, "=SUM(1,2,3)", "6"),
             make_value(119, "=P1+5", "2019-03-06 02:00:00 +00:00"),
             make_value(170, "=PRODUCT(ABS(1),2*1, 3,4*1)", "24"),
-            make_value(196, "=RIGHT(\"apple\", 3)", "ple"),
-            make_value(222, "=LEFT(\"apple\", 3)", "app"),
-            make_value(1039999974, "42", "42")
+            make_value(196, '=RIGHT("apple", 3)', "ple"),
+            make_value(222, '=LEFT("apple", 3)', "app"),
+            make_value(1039999974, "42", "42"),
         ]
         assert output == expected
 

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,7 @@ def main():`
`116`	`116`	`"mode": "snapshot",`
`117`	`117`	`"aws_skip_signature": "true",`
`118`	`118`	`},`
`119`		`- }`
	`119`	`+ },`
`120`	`120`	`}`
`121`	`121`	`]`
`122`	`122`
`@@ -132,7 +132,7 @@ def main():`
`132`	`132`	`"aws_skip_signature": "true",`
`133`	`133`	`"timestamp_column": "unix_time",`
`134`	`134`	`},`
`135`		`- }`
	`135`	`+ },`
`136`	`136`	`}`
`137`	`137`	`]`
`138`	`138`
`@@ -148,7 +148,7 @@ def main():`
`148`	`148`	`"mode": "truncate",`
`149`	`149`	`}`
`150`	`150`	`\| s3_credentials,`
`151`		`- }`
	`151`	`+ },`
`152`	`152`	`}`
`153`	`153`	`]`
`154`	`154`	`else:`
`@@ -205,7 +205,7 @@ def main():`
`205`	`205`	`"mode": "snapshot",`
`206`	`206`	`"aws_skip_signature": "true",`
`207`	`207`	`},`
`208`		`- }`
	`208`	`+ },`
`209`	`209`	`}`
`210`	`210`	`]`
`211`	`211`
`@@ -224,7 +224,7 @@ def main():`
`224`	`224`	`"timestamp_column": "unix_time",`
`225`	`225`	`"aws_skip_signature": "true",`
`226`	`226`	`},`
`227`		`- }`
	`227`	`+ },`
`228`	`228`	`}`
`229`	`229`	`]`
`230`	`230`
`@@ -240,7 +240,7 @@ def main():`
`240`	`240`	`"mode": "truncate",`
`241`	`241`	`}`
`242`	`242`	`\| s3_credentials,`
`243`		`- }`
	`243`	`+ },`
`244`	`244`	`}`
`245`	`245`	`]`
`246`	`246`	`else:`