Bumping version to 2.2.2

Author: igorborgest

README.md

@@ -2,7 +2,7 @@
 
 > Utility belt to handle data on AWS.
 
-[![Release](https://img.shields.io/badge/release-0.2.1-brightgreen.svg)](https://pypi.org/project/awswrangler/)
+[![Release](https://img.shields.io/badge/release-0.2.2-brightgreen.svg)](https://pypi.org/project/awswrangler/)
 [![Downloads](https://img.shields.io/pypi/dm/awswrangler.svg)](https://pypi.org/project/awswrangler/)
 [![Python Version](https://img.shields.io/badge/python-3.6%20%7C%203.7-brightgreen.svg)](https://pypi.org/project/awswrangler/)
 [![Documentation Status](https://readthedocs.org/projects/aws-data-wrangler/badge/?version=latest)](https://aws-data-wrangler.readthedocs.io/en/latest/?badge=latest)

awswrangler/__version__.py

@@ -1,4 +1,4 @@
 __title__ = "awswrangler"
 __description__ = "Utility belt to handle data on AWS."
-__version__ = "0.2.1"
+__version__ = "0.2.2"
 __license__ = "Apache License 2.0"

awswrangler/glue.py

@@ -269,17 +269,19 @@ def parse_table_name(path):
         return path.rpartition("/")[2]
 
     @staticmethod
-    def csv_table_definition(table, partition_cols_schema, schema, path, compression, extra_args: Optional[Dict[str, Optional[Union[str, int]]]] = None):
+    def csv_table_definition(table,
+                             partition_cols_schema,
+                             schema,
+                             path,
+                             compression,
+                             extra_args: Optional[Dict[str, Optional[Union[str, int]]]] = None):
         if extra_args is None:
-            extra_args = {
-                "sep": None
-            }
-        if extra_args.get("sep") is None:
-            extra_args["sep"] = ","
+            extra_args = {"sep": ","}
         if partition_cols_schema is None:
             partition_cols_schema = []
         compressed = False if compression is None else True
         sep = extra_args["sep"] if "sep" in extra_args else ","
+        sep = "," if sep is None else sep
         serde = extra_args.get("serde")
         if serde == "OpenCSVSerDe":
             serde_fullname = "org.apache.hadoop.hive.serde2.OpenCSVSerde"
@@ -347,6 +349,7 @@ def csv_partition_definition(partition, compression, extra_args=None):
             extra_args = {}
         compressed = False if compression is None else True
         sep = extra_args["sep"] if "sep" in extra_args else ","
+        sep = "," if sep is None else sep
         serde = extra_args.get("serde")
         if serde == "OpenCSVSerDe":
             serde_fullname = "org.apache.hadoop.hive.serde2.OpenCSVSerde"