Fixing extra whitespace in partition values

randerzander · randerzander · commit a79664733cf6 · 2022-10-04T13:45:20.000-07:00
diff --git a/dask_sql/input_utils/hive.py b/dask_sql/input_utils/hive.py
@@ -168,7 +168,7 @@ def wrapped_read_function(location, column_information, **kwargs):
                 )
                 # multiple partition column values returned comma separated string
                 if "," in partition_values:
-                    partition_values = partition_values.split(",")
+                    partition_values = [x.strip() for x in partition_values.split(",")]
 
                 logger.debug(
                     f"Applying additional partition information as columns: {partition_information}"

Original file line number	Diff line number	Diff line change
`@@ -168,7 +168,7 @@ def wrapped_read_function(location, column_information, **kwargs):`
`168`	`168`	`)`
`169`	`169`	`# multiple partition column values returned comma separated string`
`170`	`170`	`if "," in partition_values:`
`171`		`- partition_values = partition_values.split(",")`
	`171`	`+ partition_values = [x.strip() for x in partition_values.split(",")]`
`172`	`172`
`173`	`173`	`logger.debug(`
`174`	`174`	`f"Applying additional partition information as columns: {partition_information}"`