Bumping version to 0.0.7

aws · Oct 3, 2019 · 1dafb46 · 1dafb46
1 parent 79b6c3a
commit 1dafb46
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 11 deletions.
diff --git a/awswrangler/__version__.py b/awswrangler/__version__.py
@@ -1,4 +1,4 @@
 __title__ = "awswrangler"
 __description__ = "Utility belt to handle data on AWS."
-__version__ = "0.0.6"
+__version__ = "0.0.7"
 __license__ = "Apache License 2.0"
diff --git a/awswrangler/pandas.py b/awswrangler/pandas.py
@@ -646,8 +646,7 @@ def to_s3(self,
                                         procs_cpu_bound=procs_cpu_bound,
                                         procs_io_bound=procs_io_bound,
                                         cast_columns=cast_columns,
-                                        extra_args=extra_args,
-                                        inplace=inplace)
+                                        extra_args=extra_args)
         if database:
             self._session.glue.metadata_to_glue(dataframe=dataframe,
                                                 path=path,
@@ -674,8 +673,7 @@ def data_to_s3(self,
                    procs_cpu_bound=None,
                    procs_io_bound=None,
                    cast_columns=None,
-                   extra_args=None,
-                   inplace=True):
+                   extra_args=None):
         if not procs_cpu_bound:
             procs_cpu_bound = self._session.procs_cpu_bound
         if not procs_io_bound:
@@ -717,8 +715,7 @@ def data_to_s3(self,
                 session_primitives=self._session.primitives,
                 file_format=file_format,
                 cast_columns=cast_columns,
-                extra_args=extra_args,
-                isolated_dataframe=inplace)
+                extra_args=extra_args)
         if mode == "overwrite_partitions" and partition_cols:
             if procs_io_bound > procs_cpu_bound:
                 num_procs = floor(
@@ -890,7 +887,7 @@ def write_parquet_dataframe(dataframe, path, preserve_index, compression,
         dtypes = copy.deepcopy(dataframe.dtypes.to_dict())
         for name, dtype in dtypes.items():
             if str(dtype) == "Int64":
-                dataframe[name] = dataframe[name].astype("float64")
+                dataframe.loc[:, name] = dataframe[name].astype("float64")
                 casted_in_pandas.append(name)
                 cast_columns[name] = "bigint"
                 logger.debug(f"Casting column {name} Int64 to float64")

diff --git a/testing/test_awswrangler/test_cloudwatchlogs.py b/testing/test_awswrangler/test_cloudwatchlogs.py
@@ -1,6 +1,5 @@
 import logging
 from datetime import datetime
-from time import sleep
 
 import pytest
 import boto3
@@ -64,7 +63,6 @@ def logstream(cloudformation_outputs, loggroup):
     if token:
         args["sequenceToken"] = token
     client.put_log_events(**args)
-    sleep(300)
     yield logstream
 
 

diff --git a/testing/test_awswrangler/test_pandas.py b/testing/test_awswrangler/test_pandas.py
@@ -99,7 +99,6 @@ def logstream(cloudformation_outputs, loggroup):
     if token:
         args["sequenceToken"] = token
     client.put_log_events(**args)
-    sleep(300)
     yield logstream